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 <[email protected]> Authored: Fri Jul 1 14:26:59 2016 -0400 Committer: Greg Hogan <[email protected]> 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()); }
