[hotfix][cep] fix typos in cep quantifier error message

mbalassi · Oct 29, 2018 · d0d8bc6 · d0d8bc6
1 parent a13119a
commit d0d8bc6
Showing 1 changed file with 4 additions and 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
@@ -83,16 +83,16 @@ private static void checkPattern(boolean condition, Object errorMessage) {
 
  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;
  }