You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2018/03/26 07:34:50 UTC
[5/5] flink git commit: [hotfix][tests] Allow to run
SpillableSubpartitionTests in the loop
[hotfix][tests] Allow to run SpillableSubpartitionTests in the loop
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/18bcdd2f
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/18bcdd2f
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/18bcdd2f
Branch: refs/heads/release-1.5
Commit: 18bcdd2ff65c88f37d59e6016f60239d38591b73
Parents: 58a589d
Author: Piotr Nowojski <pi...@gmail.com>
Authored: Thu Mar 22 17:55:49 2018 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Mon Mar 26 09:34:18 2018 +0200
----------------------------------------------------------------------
.../io/network/partition/SpillableSubpartitionTest.java | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/18bcdd2f/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
index 840669e..15acd7c 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/io/network/partition/SpillableSubpartitionTest.java
@@ -34,6 +34,7 @@ import org.apache.flink.runtime.io.network.buffer.BufferProvider;
import org.junit.AfterClass;
import org.junit.Assert;
+import org.junit.BeforeClass;
import org.junit.Rule;
import org.junit.Test;
import org.junit.rules.ExpectedException;
@@ -74,7 +75,12 @@ public class SpillableSubpartitionTest extends SubpartitionTestBase {
private static final ExecutorService executorService = Executors.newCachedThreadPool();
/** Asynchronous I/O manager. */
- private static final IOManager ioManager = new IOManagerAsync();
+ private static IOManager ioManager;
+
+ @BeforeClass
+ public static void setup() {
+ ioManager = new IOManagerAsync();
+ }
@AfterClass
public static void shutdown() {