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 a2b8d4cc607845bb10974f2b4ec786c2a6497060 Author: Chesnay Schepler <[email protected]> AuthorDate: Thu Jun 11 19:02:31 2020 +0200 [FLINK-17977][akka] Log target address retrieval on DEBUG --- .../src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java b/flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java index cf1a815..bea3de9 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/net/ConnectionUtils.java @@ -388,7 +388,7 @@ public class ConnectionUtils { } else if (retrievalState == LeaderRetrievalState.NEWLY_RETRIEVED) { targetAddress = AkkaUtils.getInetSocketAddressFromAkkaURL(akkaURL); - LOG.info("Retrieved new target address {}.", targetAddress); + LOG.debug("Retrieved new target address {} for akka URL {}.", targetAddress, akkaURL); retrievalState = LeaderRetrievalState.RETRIEVED;
