Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 115FB200B46 for ; Fri, 1 Jul 2016 21:14:14 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 0E823160A61; Fri, 1 Jul 2016 19:14:14 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 5DC72160A4D for ; Fri, 1 Jul 2016 21:14:13 +0200 (CEST) Received: (qmail 1615 invoked by uid 500); 1 Jul 2016 19:14:12 -0000 Mailing-List: contact commits-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list commits@flink.apache.org Received: (qmail 1602 invoked by uid 99); 1 Jul 2016 19:14:12 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 01 Jul 2016 19:14:12 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 50406E009D; Fri, 1 Jul 2016 19:14:12 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: greg@apache.org To: commits@flink.apache.org Date: Fri, 01 Jul 2016 19:14:12 -0000 Message-Id: <4c1cb1006562412382800583e1e50a8b@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/5] flink git commit: [hotfix] [clients] Replace test IP with reserved address archived-at: Fri, 01 Jul 2016 19:14:14 -0000 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 Authored: Fri Jul 1 14:26:59 2016 -0400 Committer: Greg Hogan 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()); }