You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/04/22 20:40:45 UTC
[09/17] flink git commit: [FLINK-9223] [tests] bufferConsumers should
be closed in
SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd
[FLINK-9223] [tests] bufferConsumers should be closed in SpillableSubpartitionTest#testConsumeSpilledPartitionSpilledBeforeAdd
This closes #5882
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2de321e7
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2de321e7
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2de321e7
Branch: refs/heads/master
Commit: 2de321e7c5ac1390f7fcd29317e7e9a1a1faac4e
Parents: 3e702d9
Author: yanghua <ya...@gmail.com>
Authored: Fri Apr 20 14:11:45 2018 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Sun Apr 22 16:28:35 2018 +0200
----------------------------------------------------------------------
.../runtime/io/network/partition/SpillableSubpartitionTest.java | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/2de321e7/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 2e47379..817795c 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
@@ -334,6 +334,9 @@ public class SpillableSubpartitionTest extends SubpartitionTestBase {
assertTrue(reader.nextBufferIsEvent()); // end of partition event
assertNextEvent(reader, 4, EndOfPartitionEvent.class, false, 0, false, true);
assertEquals(0, partition.getBuffersInBacklog());
+
+ //close buffer consumers
+ Arrays.stream(bufferConsumers).forEach(bufferConsumer -> bufferConsumer.close());
}
/**