add debug info

Signed-off-by: zenghua <[email protected]>
lakesoul-io · Feb 7, 2024 · 856bcaa · 856bcaa
1 parent cf83977
commit 856bcaa
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lakesoul-spark/src/main/scala/org/apache/spark/sql/lakesoul/commands/CompactionCommand.scala b/lakesoul-spark/src/main/scala/org/apache/spark/sql/lakesoul/commands/CompactionCommand.scala
@@ -148,6 +148,9 @@ case class CompactionCommand(snapshotManagement: SnapshotManagement,
 
       snapshotManagement.withNewTransaction(tc => {
         val files = tc.filterFiles(targetOnlyPredicates)
+        println("[DEBUGGING]")
+        println("conditionString = " + conditionString)
+        println("tc.filterFiles(targetOnlyPredicates) = " + files)
 
         //ensure only one partition execute compaction command
         val partitionSet = files.map(_.range_partitions).toSet