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 <[email protected]> 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
