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:33:33 UTC
[3/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/1132cd7d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/1132cd7d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/1132cd7d
Branch: refs/heads/master
Commit: 1132cd7dbc541a948975ef4b69e2a85cd79c81a5
Parents: 9fbb461
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:33:06 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/1132cd7d/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() {