You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@iceberg.apache.org by pv...@apache.org on 2024/09/12 05:18:04 UTC

(iceberg) branch main updated (34cd01ba2e -> 6ff7a6ec2e)

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 34cd01ba2e Build: Upgrade google-java-format to 1.22.0 (#11050)
     add 6ff7a6ec2e Flink: Maintenance - Lock remover (#11010)

No new revisions were added by this update.

Summary of changes:
 .../maintenance/operator/JdbcLockFactory.java      |   4 +
 .../flink/maintenance/operator/LockRemover.java    | 144 ++++++++
 .../operator/TableMaintenanceMetrics.java          |   5 +
 .../operator/{Trigger.java => TaskResult.java}     |  55 ++-
 .../flink/maintenance/operator/TriggerManager.java |  14 +-
 .../flink/maintenance/operator/ManualSource.java   |  16 +-
 .../maintenance/operator/TestLockRemover.java      | 379 +++++++++++++++++++++
 7 files changed, 574 insertions(+), 43 deletions(-)
 create mode 100644 flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java
 copy flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/{Trigger.java => TaskResult.java} (52%)
 create mode 100644 flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemover.java