You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2020/06/12 12:16:02 UTC
[flink] 04/10: [FLINK-17977][runtime] Log leader grant/revocation
to shutdown JobManager on DEBUG
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 <ch...@apache.org>
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;
}