[hotfix][table] Added default branches to pattern matching to supress…

… warnings
mbalassi · Oct 29, 2018 · d23faa8 · d23faa8
1 parent 62ecdb3
commit d23faa8
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/...s/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonMatchRecognize.scala b/...s/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/CommonMatchRecognize.scala
@@ -77,6 +77,8 @@ trait CommonMatchRecognize {
  case AfterOption.SKIP_PAST_LAST_ROW => "SKIP PAST LAST ROW"
  case AfterOption.SKIP_TO_NEXT_ROW => "SKIP TO NEXT ROW"
  }
+ case _ => throw new IllegalStateException(s"Corrupted query tree. Unexpected $after for " +
+ s"after match strategy.")
  }
 
  private[flink] def matchToString(

diff --git a/...k-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamMatch.scala b/...k-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamMatch.scala
@@ -322,6 +322,8 @@ private[flink] class PatternVisitor(
  AfterMatchSkipStrategy.skipToFirst(getPatternTarget()).throwExceptionOnMiss()
  case SqlKind.SKIP_TO_LAST =>
  AfterMatchSkipStrategy.skipToLast(getPatternTarget()).throwExceptionOnMiss()
+ case _ => throw new IllegalStateException(s"Corrupted query tree. Unexpected " +
+ s"${logicalMatch.after} for after match strategy.")
  }
  }