flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [9/9] flink git commit: [hotfix] [tests] Run IPv6HostnamesITCase with parallel data exchange and less verbose output
Date Thu, 01 Oct 2015 09:54:20 GMT
[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 <sewen@apache.org>
Authored: Thu Oct 1 11:10:42 2015 +0200
Committer: Stephan Ewen <sewen@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"));
 


Mime
View raw message