paimon icon indicating copy to clipboard operation
paimon copied to clipboard

[flink] Restart dedicated compact job if schema change is detected

Open tsreaper opened this issue 4 months ago • 0 comments

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.

tsreaper avatar Aug 22 '25 09:08 tsreaper