diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java index d0769eaa5f4e..a397a069ee1d 100644 --- a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java +++ b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeletesRewrite.java @@ -136,6 +136,11 @@ public DataWriterFactory createBatchWriterFactory(PhysicalWriteInfo info) { writeProperties); } + @Override + public boolean useCommitCoordinator() { + return false; + } + @Override public void commit(WriterCommitMessage[] messages) { PositionDeletesRewriteCoordinator coordinator = PositionDeletesRewriteCoordinator.get(); diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java index 9fea33948b3e..791cbd8462a4 100644 --- a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java +++ b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkPositionDeltaWrite.java @@ -160,6 +160,11 @@ public DeltaWriterFactory createBatchWriterFactory(PhysicalWriteInfo info) { return new PositionDeltaWriteFactory(tableBroadcast, command, context, writeProperties); } + @Override + public boolean useCommitCoordinator() { + return false; + } + @Override public void commit(WriterCommitMessage[] messages) { RowDelta rowDelta = table.newRowDelta(); diff --git a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java index 15881098e7a3..96432178247d 100644 --- a/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java +++ b/spark/v3.4/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java @@ -260,6 +260,11 @@ public DataWriterFactory createBatchWriterFactory(PhysicalWriteInfo info) { return createWriterFactory(); } + @Override + public boolean useCommitCoordinator() { + return false; + } + @Override public void abort(WriterCommitMessage[] messages) { SparkWrite.this.abort(messages);