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 <[email protected]> Authored: Mon Jul 4 16:46:27 2016 +0200 Committer: Aljoscha Krettek <[email protected]> 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());
