flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aljos...@apache.org
Subject flink git commit: [hotfix] Fix AbstractKeyedCEPPatternOperator.restoreState()
Date Mon, 04 Jul 2016 14:48:42 GMT
Repository: flink
Updated Branches:
  refs/heads/master 7ee0425a3 -> b40cba609


[hotfix] Fix AbstractKeyedCEPPatternOperator.restoreState()

Before, this was trying to cast the StreamTaskState directly to a
StateHandle<DataInputView> while it should take the operator state, i.e:

StateHandle<DataInputView> stateHandle =
  (StateHandle<DataInputView>) state.getOperatorState();


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/b40cba60
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/b40cba60
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/b40cba60

Branch: refs/heads/master
Commit: b40cba60901c3e84808bed96623917ee39c4ea15
Parents: 7ee0425
Author: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Authored: Mon Jul 4 16:46:27 2016 +0200
Committer: Aljoscha Krettek <aljoscha.krettek@gmail.com>
Committed: Mon Jul 4 16:48:17 2016 +0200

----------------------------------------------------------------------
 .../apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/b40cba60/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
----------------------------------------------------------------------
diff --git a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
index 373b9f4..83892ca 100644
--- a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
+++ b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractKeyedCEPPatternOperator.java
@@ -190,7 +190,7 @@ abstract public class AbstractKeyedCEPPatternOperator<IN, KEY, OUT>
extends Abst
 		super.restoreState(state, recoveryTimestamp);
 
 		@SuppressWarnings("unchecked")
-		StateHandle<DataInputView> stateHandle = (StateHandle<DataInputView>) state;
+		StateHandle<DataInputView> stateHandle = (StateHandle<DataInputView>) state.getOperatorState();
 
 		DataInputView inputView = stateHandle.getState(getUserCodeClassloader());
 


Mime
View raw message