[flink] 01/02: [hotfix][runtime] Remove unused field from OperatorChain

[dw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 6ec5194519d7d751b4e95cb5dfa96878039ab532
Author: Dawid Wysakowicz <dw...@apache.org>
AuthorDate: Thu May 27 13:39:07 2021 +0200

    [hotfix][runtime] Remove unused field from OperatorChain
---
 .../org/apache/flink/streaming/runtime/tasks/OperatorChain.java   | 8 --------
 1 file changed, 8 deletions(-)

diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
index 10f74b9..25270bb 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/OperatorChain.java
@@ -49,7 +49,6 @@ import org.apache.flink.streaming.api.operators.StreamTaskStateInitializer;
 import org.apache.flink.streaming.runtime.io.RecordWriterOutput;
 import org.apache.flink.streaming.runtime.io.StreamTaskSourceInput;
 import org.apache.flink.streaming.runtime.streamrecord.StreamRecord;
-import org.apache.flink.streaming.runtime.streamstatus.StreamStatus;
 import org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorFactory;
 import org.apache.flink.util.FlinkException;
 import org.apache.flink.util.OutputTag;
@@ -129,13 +128,6 @@ public class OperatorChain<OUT, OP extends StreamOperator<OUT>> implements Bound
 
     private boolean ignoreEndOfInput;
 
-    /**
-     * Current status of the input stream of the operator chain. Watermarks explicitly generated by
-     * operators in the chain (i.e. timestamp assigner / watermark extractors), will be blocked and
-     * not forwarded if this value is {@link StreamStatus#IDLE}.
-     */
-    private StreamStatus streamStatus = StreamStatus.ACTIVE;
-
     public OperatorChain(
             StreamTask<OUT, OP> containingTask,
             RecordWriterDelegate<SerializationDelegate<StreamRecord<OUT>>> recordWriterDelegate) {