[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 <u...@apache.org>
Authored: Tue May 2 15:43:32 2017 +0200
Committer: Ufuk Celebi <u...@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);
 

Reply via email to