paimon
paimon copied to clipboard
[flink] Restart dedicated compact job if schema change is detected
Purpose
Currently, streaming compact job does not deal with schema change. If the user adds a column, it will be ignored by the compact job and this column will be lost.
This PR restarts the compact job if schema change is detected, so new columns will not be lost.
Tests
CompactProcedureITCase#testFailWhenSchemaChanged
API and Format
No format changes.
Documentation
No new feature.