Github user aljoscha commented on a diff in the pull request:
https://github.com/apache/flink/pull/3445#discussion_r104413873
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/operator/CEPOperatorTest.java
---
@@ -73,7 +73,8 @@ public Integer getKey(Event value) throws Exception {
false,
keySelector,
IntSerializer.INSTANCE,
- new NFAFactory()),
+ new NFAFactory(),
+ true),
--- End diff --
Ah, I see now what the parameter does. Even if you don't migrate you still
set it to true. The parameter basically indicates "would have been a keyed
operator whether we actually have legacy state or not". That's why it's always
false when restoring from the old non-keyed operator.
We just use it in the `restoreState()` method so when we don't have legacy
state the value is never actually checked.
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
