Allow recoverable execution for parallel writes

prestodb · Sep 5, 2019 · 0244ccd · 0244ccd
1 parent c594611
commit 0244ccd
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/presto-main/src/main/java/com/facebook/presto/sql/planner/PlanFragmenter.java b/presto-main/src/main/java/com/facebook/presto/sql/planner/PlanFragmenter.java
@@ -1063,8 +1063,7 @@ public GroupedExecutionProperties visitMarkDistinct(MarkDistinctNode node, Void
         public GroupedExecutionProperties visitTableWriter(TableWriterNode node, Void context)
         {
             GroupedExecutionProperties properties = node.getSource().accept(this, null);
-            // TODO (#13098): Remove partitioning and task writer count check after we have TableWriterMergeOperator
-            boolean recoveryEligible = properties.isRecoveryEligible() && (node.getPartitioningScheme().isPresent() || getTaskWriterCount(session) == 1);
+            boolean recoveryEligible = properties.isRecoveryEligible();
             if (node.getTarget() instanceof CreateHandle) {
                 recoveryEligible &= metadata.getConnectorCapabilities(session, ((CreateHandle) node.getTarget()).getHandle().getConnectorId()).contains(SUPPORTS_PARTITION_COMMIT);
             }