(iceberg) branch main updated: Flink: Move unlock from MemoryLock open to TestCase Before (#12793)

[pvary]

This is an automated email from the ASF dual-hosted git repository.

pvary pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new 6d3b38bc66 Flink: Move unlock from MemoryLock open to TestCase Before 
(#12793)
6d3b38bc66 is described below

commit 6d3b38bc66e71be9924dc56c919a26a1d5de4f70
Author: GuoYu <511955...@qq.com>
AuthorDate: Tue Apr 15 15:06:37 2025 +0800

    Flink: Move unlock from MemoryLock open to TestCase Before (#12793)
---
 .../apache/iceberg/flink/maintenance/operator/OperatorTestBase.java  | 5 +++--
 .../iceberg/flink/maintenance/operator/TestTriggerManager.java       | 1 +
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
 
b/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
index 5e05f40e53..a577e40b2c 100644
--- 
a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
+++ 
b/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/OperatorTestBase.java
@@ -94,6 +94,8 @@ public class OperatorTestBase {
   @BeforeEach
   void before() {
     LOCK_FACTORY.open();
+    LOCK_FACTORY.createLock().unlock();
+    LOCK_FACTORY.createRecoveryLock().unlock();
     MetricsReporterFactoryForTests.reset();
   }
 
@@ -242,8 +244,7 @@ public class OperatorTestBase {
 
     @Override
     public void open() {
-      MAINTENANCE_LOCK.unlock();
-      RECOVERY_LOCK.unlock();
+      // do nothing
     }
 
     @Override
diff --git 
a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
 
b/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
index a70d272794..64b24ee1b2 100644
--- 
a/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
+++ 
b/flink/v1.20/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
@@ -59,6 +59,7 @@ class TestTriggerManager extends OperatorTestBase {
 
   @BeforeEach
   void before() {
+    super.before();
     Table table = createTable();
     this.lock = LOCK_FACTORY.createLock();
     this.recoveringLock = LOCK_FACTORY.createRecoveryLock();