Repository: flink Updated Branches: refs/heads/master 3e333793c -> 0214e8003
[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/0214e800 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/0214e800 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/0214e800 Branch: refs/heads/master Commit: 0214e80033b42eb2ff8106a9d18fcf71713e66d1 Parents: 3e33379 Author: zjureel <[email protected]> Authored: Wed Aug 30 10:51:14 2017 +0800 Committer: Aljoscha Krettek <[email protected]> Committed: Mon Oct 16 10:39:39 2017 +0200 ---------------------------------------------------------------------- .../flink/streaming/api/operators/async/AsyncWaitOperator.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/0214e800/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 3dfa8aa..aec20c0 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 @@ -264,6 +264,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));
