You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2017/05/03 12:10:40 UTC
[33/50] [abbrv] flink git commit: [FLINK-6337] [network] Fix
instability in SuccessAfterNetworkBuffersFailureITCase
[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 <uc...@apache.org>
Authored: Tue May 2 15:43:32 2017 +0200
Committer: Ufuk Celebi <uc...@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);