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:03 UTC
[flink] 05/10: [FLINK-17977][akka] Log target address retrieval 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 a2b8d4cc607845bb10974f2b4ec786c2a6497060
Author: Chesnay Schepler <ch...@apache.org>
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;