This is an automated email from the ASF dual-hosted git repository.
aokolnychyi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/master by this push:
new 1f8dbae31a Core: Plan concurrently if there are multiple delete
manifests (#8388)
1f8dbae31a is described below
commit 1f8dbae31aab98654ebf4d64d37b04bff8eb22fd
Author: Anton Okolnychyi <[email protected]>
AuthorDate: Thu Aug 24 14:17:29 2023 -0700
Core: Plan concurrently if there are multiple delete manifests (#8388)
---
core/src/main/java/org/apache/iceberg/DataTableScan.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/core/src/main/java/org/apache/iceberg/DataTableScan.java
b/core/src/main/java/org/apache/iceberg/DataTableScan.java
index a889704329..6eaa0d5ec7 100644
--- a/core/src/main/java/org/apache/iceberg/DataTableScan.java
+++ b/core/src/main/java/org/apache/iceberg/DataTableScan.java
@@ -87,7 +87,7 @@ public class DataTableScan extends BaseTableScan {
manifestGroup = manifestGroup.ignoreResiduals();
}
- if (dataManifests.size() > 1 && shouldPlanWithExecutor()) {
+ if (shouldPlanWithExecutor() && (dataManifests.size() > 1 ||
deleteManifests.size() > 1)) {
manifestGroup = manifestGroup.planWith(planExecutor());
}