flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [2/4] flink git commit: [hotfix][misc] Fix logging of local port in NetworkFailuresProxy
Date Tue, 15 Aug 2017 11:51:38 GMT
[hotfix][misc] Fix logging of local port in NetworkFailuresProxy

Previously if localPort was set 0, actually obtained/bind port was not
logged anywhere. Now we print local port after binding.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ff27e206
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ff27e206
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ff27e206

Branch: refs/heads/master
Commit: ff27e206b36a0cec4bb52b6a69ecd704aa237259
Parents: 5f97ac9
Author: Piotr Nowojski <piotr.nowojski@gmail.com>
Authored: Wed Aug 9 16:26:08 2017 +0200
Committer: zentol <chesnay@apache.org>
Committed: Tue Aug 15 12:30:35 2017 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/networking/NetworkFailuresProxy.java    | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/ff27e206/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailuresProxy.java
----------------------------------------------------------------------
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailuresProxy.java
b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailuresProxy.java
index 7030049..5531811 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailuresProxy.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/networking/NetworkFailuresProxy.java
@@ -53,8 +53,6 @@ public class NetworkFailuresProxy implements AutoCloseable {
 	private final Set<NetworkFailureHandler> networkFailureHandlers = Collections.newSetFromMap(new
ConcurrentHashMap<>());
 
 	public NetworkFailuresProxy(int localPort, String remoteHost, int remotePort) {
-		LOG.info("Proxying [*:{}] to [{}:{}]", localPort, remoteHost, remotePort);
-
 		// Configure the bootstrap.
 		serverBootstrap = new ServerBootstrap(
 			new NioServerSocketChannelFactory(executor, executor));
@@ -83,6 +81,7 @@ public class NetworkFailuresProxy implements AutoCloseable {
 		});
 		channel = serverBootstrap.bind(new InetSocketAddress(localPort));
 
+		LOG.info("Proxying [*:{}] to [{}:{}]", getLocalPort(), remoteHost, remotePort);
 	}
 
 	/**


Mime
View raw message