This is an automated email from the ASF dual-hosted git repository.

dwysakowicz pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new d0d8bc6  [hotfix][cep] fix typos in cep quantifier error message
d0d8bc6 is described below

commit d0d8bc6f249ab0cf357fe74ab3e13190db0c328e
Author: Xue Yu <278006...@qq.com>
AuthorDate: Mon Oct 29 16:00:33 2018 +0800

    [hotfix][cep] fix typos in cep quantifier error message
---
 .../src/main/java/org/apache/flink/cep/pattern/Quantifier.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
 
b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
index 719f040..d0c47ac 100644
--- 
a/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
+++ 
b/flink-libraries/flink-cep/src/main/java/org/apache/flink/cep/pattern/Quantifier.java
@@ -83,16 +83,16 @@ public class Quantifier {
 
        public void combinations() {
                checkPattern(!hasProperty(QuantifierProperty.SINGLE), 
"Combinations not applicable to " + this + "!");
-               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.STRICT, "You can apply apply either combinations or 
consecutive, not both!");
+               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.STRICT, "You can apply either combinations or consecutive, 
not both!");
                checkPattern(innerConsumingStrategy != 
ConsumingStrategy.SKIP_TILL_ANY, "Combinations already applied!");
 
                innerConsumingStrategy = ConsumingStrategy.SKIP_TILL_ANY;
        }
 
        public void consecutive() {
-               checkPattern(hasProperty(QuantifierProperty.LOOPING) || 
hasProperty(QuantifierProperty.TIMES), "Combinations not applicable to " + this 
+ "!");
-               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.SKIP_TILL_ANY, "You can apply apply either combinations or 
consecutive, not both!");
-               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.STRICT, "Combinations already applied!");
+               checkPattern(hasProperty(QuantifierProperty.LOOPING) || 
hasProperty(QuantifierProperty.TIMES), "Consecutive not applicable to " + this 
+ "!");
+               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.SKIP_TILL_ANY, "You can apply either combinations or 
consecutive, not both!");
+               checkPattern(innerConsumingStrategy != 
ConsumingStrategy.STRICT, "Consecutive already applied!");
 
                innerConsumingStrategy = ConsumingStrategy.STRICT;
        }

Reply via email to