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
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
