Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6170
---
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197716343
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -658,20 +668,26 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197716214
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -229,7 +206,7 @@ public void testSimplePatternEventTime() throws
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197717301
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -580,12 +563,17 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197716849
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -512,12 +491,16 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197716928
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -512,12 +491,16 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r197717352
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -666,12 +654,17 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195826270
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -708,10 +724,32 @@ public boolean filter(Tuple2 rec)
throws
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824130
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -573,19 +577,25 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824665
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -658,20 +668,26 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195823948
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -360,27 +345,30 @@ public boolean filter(Event value) throws
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824079
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -504,20 +498,30 @@ public String select(Map>
pattern) {
Github user zentol commented on a diff in the pull request:
https://github.com/apache/flink/pull/6170#discussion_r195824580
--- Diff:
flink-libraries/flink-cep/src/test/java/org/apache/flink/cep/CEPITCase.java ---
@@ -708,10 +724,32 @@ public boolean filter(Tuple2 rec)
throws
GitHub user deepaks4077 opened a pull request:
https://github.com/apache/flink/pull/6170
[FLINK-9563]: Using a custom sink function for tests in CEPITCase instead
of writing to disk
## What is the purpose of the change
This change modifies the CEPITCase integration test to
14 matches
Mail list logo
