This is an automated email from the ASF dual-hosted git repository.
arvid pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 8addf89 [FLINK-19907][network] Recover channel state before
initializing operators chain
8addf89 is described below
commit 8addf891ad97ce83bb22c559aef28411f3953014
Author: Roman Khachatryan <[email protected]>
AuthorDate: Sat Oct 31 18:03:19 2020 +0100
[FLINK-19907][network] Recover channel state before initializing operators
chain
Otherwise, operators in chain can emit watermarks or other data before
the old data is being sent to the downstream.
---
.../java/org/apache/flink/streaming/runtime/tasks/StreamTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
index aa25aeb..e00ec13 100644
---
a/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
+++
b/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java
@@ -476,9 +476,9 @@ public abstract class StreamTask<OUT, OP extends
StreamOperator<OUT>>
// both the following operations are protected by the
lock
// so that we avoid race conditions in the case that
initializeState()
// registers a timer, that fires before the open() is
called.
-
operatorChain.initializeStateAndOpenOperators(createStreamTaskStateInitializer());
+ readRecoveredChannelState(); // WARN: should be done
before operatorChain.initializeStateAndOpenOperators (see FLINK-19907)
- readRecoveredChannelState();
+
operatorChain.initializeStateAndOpenOperators(createStreamTaskStateInitializer());
});
isRunning = true;
