Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198472927
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFAState.java
---
@@ -79,18 +98,18 @@ public boolean equals(Object o) {
return false;
}
NFAState nfaState = (NFAState) o;
- return Objects.equals(computationStates,
nfaState.computationStates);
+ return Objects.equals(partialMatches, nfaState.partialMatches);
--- End diff --
What about the `completedMatches`?
---