提交 b40cba60 编写于 作者: A Aljoscha Krettek

[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();
上级 7ee0425a
......@@ -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());
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册