From 1955542435cd4c5467c4309cbecdd4a66a7ac519 Mon Sep 17 00:00:00 2001 From: hezhao2 Date: Fri, 15 Dec 2023 13:33:14 +0800 Subject: [PATCH] fix --- .../scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/extensions/spark/kyuubi-extension-spark-3-4/src/main/scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala b/extensions/spark/kyuubi-extension-spark-3-4/src/main/scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala index 42e9a3fbea0..34b3b3405ae 100644 --- a/extensions/spark/kyuubi-extension-spark-3-4/src/main/scala/org/apache/kyuubi/sql/watchdog/MaxScanStrategy.scala +++ b/extensions/spark/kyuubi-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