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
