add debug info

Signed-off-by: zenghua <[email protected]>
lakesoul-io · Feb 7, 2024 · c92a114 · c92a114
1 parent 890d9fe
commit c92a114
Showing 1 changed file with 2 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
@@ -103,6 +103,8 @@ case class CompactionCommand(snapshotManagement: SnapshotManagement,
     if (readPartitionInfo.nonEmpty) {
       map.put("partValue", readPartitionInfo.head.range_value)
     }
+    println("map = " + map)
+
 
     val (newFiles, path) = tc.writeFiles(compactDF, Some(new LakeSoulOptions(map.toMap, spark.sessionState.conf)), isCompaction = true)
     tc.commit(newFiles, Seq.empty, readPartitionInfo)