You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2018/01/03 12:44:52 UTC
flink git commit: [FLINK-7495] Call to
AbstractUdfStreamOperator#initializeState() in the beginning
Repository: flink
Updated Branches:
refs/heads/release-1.3 6cdbf9117 -> a315fb78e
[FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a315fb78
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a315fb78
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a315fb78
Branch: refs/heads/release-1.3
Commit: a315fb78e81d4ee260efd77bcc107e46dfdbcc7e
Parents: 6cdbf91
Author: zjureel <zj...@gmail.com>
Authored: Wed Aug 30 10:51:14 2017 +0800
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Wed Jan 3 13:44:33 2018 +0100
----------------------------------------------------------------------
.../flink/streaming/api/operators/async/AsyncWaitOperator.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a315fb78/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
index 17dec23..0a93b96 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/AsyncWaitOperator.java
@@ -266,6 +266,7 @@ public class AsyncWaitOperator<IN, OUT>
@Override
public void initializeState(StateInitializationContext context) throws Exception {
+ super.initializeState(context);
recoveredStreamElements = context
.getOperatorStateStore()
.getListState(new ListStateDescriptor<>(STATE_NAME, inStreamElementSerializer));