explicit check match

apache · Jan 3, 2018 · 8d16109 · 8d16109
1 parent 8f3629d
commit 8d16109
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala b/sql/core/src/main/scala/org/apache/spark/sql/streaming/StreamingQueryManager.scala
@@ -266,7 +266,7 @@ class StreamingQueryManager private[sql] (sparkSession: SparkSession) extends Lo
           outputMode,
           extraOptions,
           deleteCheckpointOnStop))
-      case _ =>
+      case (_: ContinuousWriteSupport, t) if !t.isInstanceOf[ContinuousTrigger] =>
         throw new AnalysisException(
           "Sink only supports continuous writes, but a continuous trigger was not specified.")
     }