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 2025/04/15 07:06:43 UTC
(iceberg) branch main updated: Flink: Move unlock from MemoryLock open to TestCase Before (#12793)
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 <51...@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();