This is an automated email from the ASF dual-hosted git repository.
pvary pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
from f2d62757e2 Flink: Port #10484 to v1.20 (#10989)
add aa1ecc817b Flink: Maintenance - TableChange refactor (#10992)
No new revisions were added by this update.
Summary of changes:
.../maintenance/operator/JdbcLockFactory.java | 14 +-
.../flink/maintenance/operator/TableChange.java | 193 ++++++++++++++-------
.../maintenance/operator/TriggerEvaluator.java | 85 +++++----
.../maintenance/operator/TestMonitorSource.java | 27 +--
.../maintenance/operator/TestTriggerManager.java | 182 ++++++++++++-------
5 files changed, 329 insertions(+), 172 deletions(-)