Github user kl0u commented on a diff in the pull request: https://github.com/apache/flink/pull/6171#discussion_r198472975 --- 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); } @Override public int hashCode() { - return Objects.hash(computationStates, stateChanged); + return Objects.hash(partialMatches, stateChanged); --- End diff -- Same as above.
---