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:04 UTC
[flink] 06/10: [FLINK-17977][runtime] Log registration attempts 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 016479a2ba16d52c22ab23ab0c8e0e416a3667ed
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Thu Jun 11 19:07:40 2020 +0200
[FLINK-17977][runtime] Log registration attempts on DEBUG
---
.../org/apache/flink/runtime/registration/RetryingRegistration.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistration.java b/flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistration.java
index 828cc26..a681501 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistration.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/registration/RetryingRegistration.java
@@ -171,7 +171,7 @@ public abstract class RetryingRegistration<F extends Serializable, G extends Rpc
strippedFailure);
} else {
log.info(
- "Could not resolve {} address {}, retrying in {} ms: {}.",
+ "Could not resolve {} address {}, retrying in {} ms: {}",
targetName,
targetAddress,
retryingRegistrationConfiguration.getErrorDelayMillis(),
@@ -201,7 +201,7 @@ public abstract class RetryingRegistration<F extends Serializable, G extends Rpc
}
try {
- log.info("Registration at {} attempt {} (timeout={}ms)", targetName, attempt, timeoutMillis);
+ log.debug("Registration at {} attempt {} (timeout={}ms)", targetName, attempt, timeoutMillis);
CompletableFuture<RegistrationResponse> registrationFuture = invokeRegistration(gateway, fencingToken, timeoutMillis);
// if the registration was successful, let the TaskExecutor know