Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on PR #11010: URL: https://github.com/apache/iceberg/pull/11010#issuecomment-2345295003 Merged to main. Thanks for the review @stevenzwu and @advancedxy! -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary merged PR #11010: URL: https://github.com/apache/iceberg/pull/11010 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@iceberg.apa

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on PR #11010: URL: https://github.com/apache/iceberg/pull/11010#issuecomment-2343218837 @stevenzwu: I didn't get answer for my question on the Flink dev list about the output of the PostCommitTopology. See: https://lists.apache.org/thread/28qb1q6b7kz30dqjdbsw855osx4t38s7

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1752285973 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1739164510 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,152 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

advancedxy commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1735621044 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MaintenanceResult.java: ## @@ -0,0 +1,71 @@ +/* + * Licensed to the Apache Softwar

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733430117 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TableMaintenanceMetrics.java: ## @@ -28,6 +28,11 @@ public class TableMaintenanceMetric

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733429843 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733429045 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733428833 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResult.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733428026 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733427810 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733426011 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

stevenzwu commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733272574 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

stevenzwu commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733165075 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

stevenzwu commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733146479 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

stevenzwu commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1733119833 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732409874 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732394823 ## flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestLockRemover.java: ## @@ -0,0 +1,234 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732394410 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732393890 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732248384 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732242350 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MaintenanceResult.java: ## @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732238099 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/TaskResult.java: ## @@ -0,0 +1,65 @@ +/* + * Licensed to the Apache Software Foundation

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732237513 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/MaintenanceResult.java: ## @@ -0,0 +1,93 @@ +/* + * Licensed to the Apache Software Fou

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732235950 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732235043 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732232054 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

pvary commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1732217490 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foundati

Re: [PR] Flink: Maintenance - Lock remover [iceberg]

stevenzwu commented on code in PR #11010: URL: https://github.com/apache/iceberg/pull/11010#discussion_r1731685941 ## flink/v1.20/flink/src/main/java/org/apache/iceberg/flink/maintenance/operator/LockRemover.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun