apache / paimon

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
https://paimon.apache.org/
Apache License 2.0
2.43k stars 956 forks source link

[flink] support setting uid suffix for source/sink to improve state compatibility when jobGraph changes. #4425

Closed liming30 closed 2 weeks ago

liming30 commented 3 weeks ago

Purpose

Linked issue: close #4424

[flink] support setting uid suffix for source/sink to improve state compatibility when jobGraph changes.

Tests

  1. org.apache.paimon.flink.FlinkJobRecoveryITCase

API and Format

No

Documentation

wwj6591812 commented 2 weeks ago

+1