flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject [5/5] flink git commit: [hotfix][tests] Allow to run SpillableSubpartitionTests in the loop
Date Mon, 26 Mar 2018 07:34:50 GMT
[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 <piotr.nowojski@gmail.com>
Authored: Thu Mar 22 17:55:49 2018 +0100
Committer: Till Rohrmann <trohrmann@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() {


Mime
View raw message