Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6171
---
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198474417
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -330,77 +328,85 @@ private boolean isStateTimedOut(final
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198473426
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/aftermatch/AfterMatchSkipStrategy.java
---
@@ -0,0 +1,155 @@
+/*
+ *
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) {
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) {
Github user kl0u commented on a diff in the pull request:
https://github.com/apache/flink/pull/6171#discussion_r198473858
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/nfa/NFA.java ---
@@ -330,77 +328,85 @@ private boolean isStateTimedOut(final
GitHub user dawidwys opened a pull request:
https://github.com/apache/flink/pull/6171
[FLINK-9593] Unified After Match semantics with SQL MATCH_RECOGNIZE
## What is the purpose of the change
Unify semantics of AfteMatch skip with SQL standard to enable CEP ans SQL
