You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by pn...@apache.org on 2019/07/04 11:30:20 UTC
[flink] 02/06: [hotfix][test] Drop unused closedChannels field in
MockInputGate
This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit de9168423ecc322e3d52d3ce584757612fef9693
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Thu Jun 27 12:28:47 2019 +0200
[hotfix][test] Drop unused closedChannels field in MockInputGate
---
.../test/java/org/apache/flink/streaming/runtime/io/MockInputGate.java | 3 ---
1 file changed, 3 deletions(-)
diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/MockInputGate.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/MockInputGate.java
index 5f95e17..65984f4 100644
--- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/MockInputGate.java
+++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/MockInputGate.java
@@ -39,8 +39,6 @@ public class MockInputGate extends InputGate {
private final boolean[] closed;
- private int closedChannels;
-
MockInputGate(int numberOfChannels, List<BufferOrEvent> bufferOrEvents) {
this.numberOfChannels = numberOfChannels;
this.bufferOrEvents = new ArrayDeque<BufferOrEvent>(bufferOrEvents);
@@ -77,7 +75,6 @@ public class MockInputGate extends InputGate {
}
if (next.isEvent() && next.getEvent() instanceof EndOfPartitionEvent) {
closed[channelIdx] = true;
- closedChannels++;
}
return Optional.of(next);
}