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 13:02:43 UTC
(iceberg) branch main updated: Flink: Fix TriggerManager parameter list for recovery tests (#12800)
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 913e243d15 Flink: Fix TriggerManager parameter list for recovery tests (#12800)
913e243d15 is described below
commit 913e243d1551932a31a0cd72d2318ee8cf96b0e0
Author: GuoYu <51...@qq.com>
AuthorDate: Tue Apr 15 21:02:38 2025 +0800
Flink: Fix TriggerManager parameter list for recovery tests (#12800)
---
.../apache/iceberg/flink/maintenance/operator/TestTriggerManager.java | 2 +-
.../apache/iceberg/flink/maintenance/operator/TestTriggerManager.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java b/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
index 5666e3e985..63bea00f34 100644
--- a/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
+++ b/flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/maintenance/operator/TestTriggerManager.java
@@ -594,7 +594,7 @@ class TestTriggerManager extends OperatorTestBase {
private static Stream<Arguments> parametersForTestRecovery() {
return Stream.of(
- Arguments.of(true, false),
+ Arguments.of(true, true),
Arguments.of(true, false),
Arguments.of(false, true),
Arguments.of(false, false));
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 5666e3e985..63bea00f34 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
@@ -594,7 +594,7 @@ class TestTriggerManager extends OperatorTestBase {
private static Stream<Arguments> parametersForTestRecovery() {
return Stream.of(
- Arguments.of(true, false),
+ Arguments.of(true, true),
Arguments.of(true, false),
Arguments.of(false, true),
Arguments.of(false, false));