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());
     }
 

Reply via email to