flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From g...@apache.org
Subject [1/5] flink git commit: [hotfix] [clients] Replace test IP with reserved address
Date Fri, 01 Jul 2016 19:14:12 GMT
Repository: flink
Updated Branches:
  refs/heads/master 7ab6837fd -> bdfcf10c4


[hotfix] [clients] Replace test IP with reserved address


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

Branch: refs/heads/master
Commit: bdfcf10c4764b44575844730fc9d900ec42a8dcf
Parents: 5ca0640
Author: Greg Hogan <code@greghogan.com>
Authored: Fri Jul 1 14:26:59 2016 -0400
Committer: Greg Hogan <code@greghogan.com>
Committed: Fri Jul 1 14:35:42 2016 -0400

----------------------------------------------------------------------
 .../client/CliFrontendAddressConfigurationTest.java   | 14 +++++---------
 1 file changed, 5 insertions(+), 9 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/bdfcf10c/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
----------------------------------------------------------------------
diff --git a/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
b/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
index 0119dbe..41d8622 100644
--- a/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
+++ b/flink-clients/src/test/java/org/apache/flink/client/CliFrontendAddressConfigurationTest.java
@@ -18,14 +18,7 @@
 
 package org.apache.flink.client;
 
-import static org.apache.flink.client.CliFrontendTestUtils.checkJobManagerAddress;
-import static org.junit.Assert.fail;
-
-import static org.mockito.Mockito.*;
-
 import org.apache.flink.client.cli.CliFrontendParser;
-import org.apache.flink.client.cli.CommandLineOptions;
-
 import org.apache.flink.client.cli.RunOptions;
 import org.apache.flink.client.program.ClusterClient;
 import org.apache.flink.configuration.Configuration;
@@ -38,6 +31,9 @@ import org.junit.rules.TemporaryFolder;
 
 import java.net.InetSocketAddress;
 
+import static org.apache.flink.client.CliFrontendTestUtils.checkJobManagerAddress;
+import static org.junit.Assert.fail;
+
 /**
  * Tests that verify that the CLI client picks up the correct address for the JobManager
  * from configuration and configs.
@@ -89,12 +85,12 @@ public class CliFrontendAddressConfigurationTest {
 		try {
 			CliFrontend frontend = new CliFrontend(CliFrontendTestUtils.getConfigDir());
 
-			RunOptions options = CliFrontendParser.parseRunCommand(new String[] {"-m", "10.221.130.22:7788"});
+			RunOptions options = CliFrontendParser.parseRunCommand(new String[] {"-m", "203.0.113.22:7788"});
 
 			ClusterClient client = frontend.retrieveClient(options);
 			Configuration config = client.getFlinkConfiguration();
 
-			InetSocketAddress expectedAddress = new InetSocketAddress("10.221.130.22", 7788);
+			InetSocketAddress expectedAddress = new InetSocketAddress("203.0.113.22", 7788);
 
 			checkJobManagerAddress(config, expectedAddress.getHostName(), expectedAddress.getPort());
 		}


Mime
View raw message