You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2015/10/01 11:54:20 UTC
[9/9] flink git commit: [hotfix] [tests] Run IPv6HostnamesITCase with
parallel data exchange and less verbose output
[hotfix] [tests] Run IPv6HostnamesITCase with parallel data exchange and less verbose output
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/846ad706
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/846ad706
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/846ad706
Branch: refs/heads/master
Commit: 846ad70642f755b39bd41f6f13b8f6aa5e98ac7d
Parents: 41717d1
Author: Stephan Ewen <se...@apache.org>
Authored: Thu Oct 1 11:10:42 2015 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Thu Oct 1 11:10:42 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/846ad706/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java b/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java
index e976c23..b4a5018 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/runtime/IPv6HostnamesITCase.java
@@ -80,7 +80,9 @@ public class IPv6HostnamesITCase extends TestLogger {
flink.start();
ExecutionEnvironment env = ExecutionEnvironment.createRemoteEnvironment(addressString, flink.getLeaderRPCPort());
-
+ env.setParallelism(4);
+ env.getConfig().disableSysoutLogging();
+
// get input data
DataSet<String> text = env.fromElements(WordCountData.TEXT.split("\n"));