This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch release-1.11 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 556ef942e4d7cb9ee3c221cee51adc6bbd3c1996 Author: Chesnay Schepler <[email protected]> AuthorDate: Thu Jun 11 19:01:47 2020 +0200 [FLINK-17977][runtime] Log leader grant/revocation to shutdown JobManager on DEBUG --- .../java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java index a6108d8..4d750d4 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/jobmaster/JobManagerRunnerImpl.java @@ -272,7 +272,7 @@ public class JobManagerRunnerImpl implements LeaderContender, OnCompletionAction public void grantLeadership(final UUID leaderSessionID) { synchronized (lock) { if (shutdown) { - log.info("JobManagerRunner already shutdown."); + log.debug("JobManagerRunner cannot be granted leadership because it is already shut down."); return; } @@ -365,7 +365,7 @@ public class JobManagerRunnerImpl implements LeaderContender, OnCompletionAction public void revokeLeadership() { synchronized (lock) { if (shutdown) { - log.info("JobManagerRunner already shutdown."); + log.debug("Ignoring revoking leadership because JobManagerRunner is already shut down."); return; }
