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 <[email protected]> Authored: Wed Aug 30 10:51:14 2017 +0800 Committer: Aljoscha Krettek <[email protected]> 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));
