revert

apache · Sep 17, 2024 · 0658c4f · 0658c4f
1 parent 1fd8aa4
commit 0658c4f
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...k/src/main/java/org/apache/iceberg/spark/actions/SparkBinPackPositionDeletesRewriter.java b/...k/src/main/java/org/apache/iceberg/spark/actions/SparkBinPackPositionDeletesRewriter.java
@@ -103,7 +103,7 @@ protected void doRewrite(String groupId, List<PositionDeletesScanTask> group) {
             .option(SparkReadOptions.SCAN_TASK_SET_ID, groupId)
             .option(SparkReadOptions.SPLIT_SIZE, splitSize(inputSize(group)))
             .option(SparkReadOptions.FILE_OPEN_COST, "0")
-            .load(table().name());
+            .load(groupId);
 
     // keep only valid position deletes
     Dataset<Row> dataFiles = dataFiles(partitionType, partition);
@@ -118,7 +118,7 @@ protected void doRewrite(String groupId, List<PositionDeletesScanTask> group) {
         .option(SparkWriteOptions.REWRITTEN_FILE_SCAN_TASK_SET_ID, groupId)
         .option(SparkWriteOptions.TARGET_DELETE_FILE_SIZE_BYTES, writeMaxFileSize())
         .mode("append")
-        .save(table().name());
+        .save(groupId);
   }
 
   /** Returns entries of {@link DataFilesTable} of specified partition */

diff --git a/...v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingDataRewriter.java b/...v3.5/spark/src/main/java/org/apache/iceberg/spark/actions/SparkShufflingDataRewriter.java
@@ -124,7 +124,7 @@ public void doRewrite(String groupId, List<FileScanTask> group) {
             .read()
             .format("iceberg")
             .option(SparkReadOptions.SCAN_TASK_SET_ID, groupId)
-            .load(table().name());
+            .load(groupId);
 
     Dataset<Row> sortedDF = sortedDF(scanDF, sortFunction(group));
 
@@ -136,7 +136,7 @@ public void doRewrite(String groupId, List<FileScanTask> group) {
         .option(SparkWriteOptions.USE_TABLE_DISTRIBUTION_AND_ORDERING, "false")
         .option(SparkWriteOptions.OUTPUT_SPEC_ID, outputSpecId())
         .mode("append")
-        .save(table().name());
+        .save(groupId);
   }
 
   private Function<Dataset<Row>, Dataset<Row>> sortFunction(List<FileScanTask> group) {