rebase master

liming30 · Nov 13, 2023 · 0a01527 · 0a01527
1 parent 983173d
commit 0a01527
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...c/main/java/org/apache/paimon/flink/source/assigners/DynamicPartitionPruningAssigner.java b/...c/main/java/org/apache/paimon/flink/source/assigners/DynamicPartitionPruningAssigner.java
@@ -31,6 +31,7 @@
 import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
+import java.util.Optional;
 import java.util.stream.Collectors;
 
 /** Assigner to perform dynamic partition pruning by given {@link DynamicFilteringData}. */
@@ -83,6 +84,11 @@ public Collection<FileStoreSourceSplit> remainingSplits() {
                 .collect(Collectors.toList());
     }
 
+    @Override
+    public Optional<Long> getNextSnapshotId(int subtask) {
+        return innerAssigner.getNextSnapshotId(subtask);
+    }
+
     private boolean filter(FileStoreSourceSplit sourceSplit) {
         DataSplit dataSplit = (DataSplit) sourceSplit.split();
         BinaryRow partition = dataSplit.partition();