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 9c7a3e3148ad433c74b0afbae57e467e4ef19940 Author: Chesnay Schepler <[email protected]> AuthorDate: Thu Jun 11 19:13:51 2020 +0200 [FLINK-17977][runtime] Log outdated TaskExecutor registration on DEBUG --- .../java/org/apache/flink/runtime/resourcemanager/ResourceManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java index b4c0133..8c83a38 100755 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/resourcemanager/ResourceManager.java @@ -392,7 +392,7 @@ public abstract class ResourceManager<WorkerType extends ResourceIDRetrievable> return registerTaskExecutorInternal(taskExecutorGateway, taskExecutorRegistration); } } else { - log.info("Ignoring outdated TaskExecutorGateway connection."); + log.debug("Ignoring outdated TaskExecutorGateway connection for {}.", resourceId); return new RegistrationResponse.Decline("Decline outdated task executor registration."); } },
