[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);