diff --git a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java index a7c1234a79a3..58d77695f27d 100644 --- a/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java +++ b/spark/v3.5/spark/src/main/java/org/apache/iceberg/spark/source/SparkWrite.java @@ -506,6 +506,11 @@ public StreamingDataWriterFactory createStreamingWriterFactory(PhysicalWriteInfo return createWriterFactory(); } + @Override + public boolean useCommitCoordinator() { + return false; + } + @Override public final void commit(long epochId, WriterCommitMessage[] messages) { LOG.info("Committing epoch {} for query {} in {} mode", epochId, queryId, mode());