flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [33/50] [abbrv] flink git commit: [FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase
Date Wed, 03 May 2017 12:10:40 GMT
[FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersFailureITCase

The reduced number of network buffers as part of this issue was too low and
lead to instable tests.


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

Branch: refs/heads/table-retraction
Commit: aa8f81ccdf6a91cd95e29ce501fd7b454d516264
Parents: 2d33c0b
Author: Ufuk Celebi <uce@apache.org>
Authored: Tue May 2 15:43:32 2017 +0200
Committer: Ufuk Celebi <uce@apache.org>
Committed: Tue May 2 15:44:04 2017 +0200

----------------------------------------------------------------------
 .../flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/aa8f81cc/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
----------------------------------------------------------------------
diff --git a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
index 710e7df..4f24452 100644
--- a/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
+++ b/flink-tests/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
@@ -42,7 +42,6 @@ import static org.junit.Assert.*;
 
 public class SuccessAfterNetworkBuffersFailureITCase extends TestLogger {
 	
-	
 	@Test
 	public void testSuccessfulProgramAfterFailure() {
 		LocalFlinkMiniCluster cluster = null;
@@ -52,7 +51,7 @@ public class SuccessAfterNetworkBuffersFailureITCase extends TestLogger
{
 			config.setInteger(ConfigConstants.LOCAL_NUMBER_TASK_MANAGER, 2);
 			config.setLong(TaskManagerOptions.MANAGED_MEMORY_SIZE, 80L);
 			config.setInteger(ConfigConstants.TASK_MANAGER_NUM_TASK_SLOTS, 8);
-			config.setInteger(TaskManagerOptions.NETWORK_NUM_BUFFERS, 640);
+			config.setInteger(TaskManagerOptions.NETWORK_NUM_BUFFERS, 800);
 			
 			cluster = new LocalFlinkMiniCluster(config, false);
 


Mime
View raw message