Open nsivabalan opened 2 weeks ago
I do see some usages for Flink auto commit:
FlinkDeleteHelper
, the logic does not work at all before and we can just replace it with commit;FlinkDeletePartitionCommitActionExecutor
, Flink explicitly enabled the auto-commit in HoodieCatalogUtil.createWriteClient
.
Change Logs
Describe context and summary for this change. Highlight if any code was copied.
Impact
Describe any public API or user-facing feature change or any performance impact.
Risk level (write none, low medium or high below)
If medium or high, explain what verification was done to mitigate the risks.
Documentation Update
Describe any necessary documentation update if there is any new feature, config, or user-facing change. If not, put "none".
Contributor's checklist