fix(sink): fix iceberg sink missing deletes (#15779)

risingwavelabs · Mar 19, 2024 · 5545276 · 5545276
1 parent 4f2f65e
commit 5545276
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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::<Result<Vec<WriteResult>>>()?;
-        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(());
         }