[FLINK-6337] [network] Fix instability in SuccessAfterNetworkBuffersF…

…ailureITCase The reduced number of network buffers as part of this issue was too low and lead to instable tests.
silenceland · May 2, 2017 · aa8f81c · aa8f81c
1 parent 2d33c0b
commit aa8f81c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...sts/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java b/...sts/src/test/java/org/apache/flink/test/misc/SuccessAfterNetworkBuffersFailureITCase.java
@@ -42,7 +42,6 @@
 
 public class SuccessAfterNetworkBuffersFailureITCase extends TestLogger {
 
-
 	@Test
 	public void testSuccessfulProgramAfterFailure() {
 		LocalFlinkMiniCluster cluster = null;
@@ -52,7 +51,7 @@ public void testSuccessfulProgramAfterFailure() {
 			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);