diff --git a/src/connector/src/sink/iceberg/mod.rs b/src/connector/src/sink/iceberg/mod.rs index 374f8a925b1f0..6eb8cd2d53f6b 100644 --- a/src/connector/src/sink/iceberg/mod.rs +++ b/src/connector/src/sink/iceberg/mod.rs @@ -942,7 +942,7 @@ impl SinkCommitCoordinator for IcebergSinkCommitter { .iter() .map(|meta| WriteResult::try_from(meta, &self.partition_type)) .collect::>>()?; - if write_results.is_empty() || write_results.iter().all(|r| r.data_files.is_empty()) { + if write_results.is_empty() { tracing::debug!(?epoch, "no data to commit"); return Ok(()); }