flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [FLINK-7495] Call to AbstractUdfStreamOperator#initializeState() in the beginning
Date Mon, 16 Oct 2017 08:40:17 GMT
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 <zjureel@gmail.com>
Authored: Wed Aug 30 10:51:14 2017 +0800
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
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));


Mime
View raw message