fix

apache · Dec 15, 2023 · 1955542 · 1955542
1 parent 495806e
commit 1955542
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...i-extension-spark-3-4/src/main/scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala b/...i-extension-spark-3-4/src/main/scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala
@@ -248,7 +248,7 @@ case class MaxScanStrategy(session: SparkSession)
           .builder("isIcebergRelation")
           .impl(Class.forName("org.apache.spark.sql.catalyst.utils.PlanUtils"))
           .buildChecked.invoke[Boolean](relation.relation)
-        if (isIcebergRelation) {
+        if (!isIcebergRelation) {
           return
         }
         val icebergTable = relation.relation.table