fix

apache · Nov 18, 2024 · b9afb4c · b9afb4c
1 parent a40f498
commit b9afb4c
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 7 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/source/StreamDataTableScan.java b/paimon-core/src/main/java/org/apache/paimon/table/source/StreamDataTableScan.java
@@ -29,10 +29,4 @@ public interface StreamDataTableScan extends DataTableScan, StreamTableScan {
 
     /** Restore from checkpoint next snapshot id with scan kind. */
     void restore(@Nullable Long nextSnapshotId, boolean scanAllSnapshot);
-
-    @Override
-    default StreamDataTableScan dropStats() {
-        // do nothing, should implement this if need
-        return this;
-    }
 }
diff --git a/...ark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/sources/StreamHelper.scala b/...ark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/sources/StreamHelper.scala
@@ -44,7 +44,8 @@ private[spark] trait StreamHelper {
 
   var lastTriggerMillis: Long
 
-  private lazy val streamScan: StreamDataTableScan = table.newStreamScan().dropStats()
+  private lazy val streamScan: StreamDataTableScan =
+    table.newStreamScan().dropStats().asInstanceOf[StreamDataTableScan]
 
   private lazy val partitionSchema: StructType =
     SparkTypeUtils.fromPaimonRowType(TypeUtils.project(table.rowType(), table.partitionKeys()))