You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by wa...@apache.org on 2022/08/27 10:18:46 UTC
[flink] branch master updated: [FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents'
This is an automated email from the ASF dual-hosted git repository.
wangyang0918 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 7b394a3ddd5 [FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents'
7b394a3ddd5 is described below
commit 7b394a3ddd57e1bf88426fad92090f93fcdf6e4d
Author: wangyang0918 <da...@alibaba-inc.com>
AuthorDate: Fri Aug 26 13:25:21 2022 +0800
[FLINK-29105][k8s] Fix the unstable k8s test 'testAddAndLockShouldNotThrowAlreadyExistExceptionWithSameContents'
---
.../kubernetes/highavailability/KubernetesStateHandleStoreTest.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java
index 2d58f93a8fe..1a76790513b 100644
--- a/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java
+++ b/flink-kubernetes/src/test/java/org/apache/flink/kubernetes/highavailability/KubernetesStateHandleStoreTest.java
@@ -1208,7 +1208,8 @@ class KubernetesStateHandleStoreTest extends KubernetesHighAvailabilityTestBase
+ "kubernetes client operation");
}
return true;
- }),
+ },
+ Executors.newDirectExecutorService()),
KubernetesConfigOptions.KUBERNETES_TRANSACTIONAL_OPERATION_MAX_RETRIES
.defaultValue(),
t ->
@@ -1216,6 +1217,7 @@ class KubernetesStateHandleStoreTest extends KubernetesHighAvailabilityTestBase
.isPresent(),
Executors.newDirectExecutorService());
assertThat(callbackInvocationCount.get()).isEqualTo(2);
+ assertThat(result).isCompleted();
return result;
}
}