Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81200110
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void resto
Github user jaxbihani commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81199485
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void resto
Github user greghogan commented on a diff in the pull request:
https://github.com/apache/flink/pull/2568#discussion_r81155827
--- Diff:
flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/operator/AbstractCEPPatternOperator.java
---
@@ -126,11 +126,12 @@ public void resto
GitHub user jaxbihani opened a pull request:
https://github.com/apache/flink/pull/2568
[FLINK-4636] Add boundary check for priorityqueue for cep operator
Thanks for contributing to Apache Flink. Before you open your pull request,
please take the following check list into considerati
