This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch exp_github_actions
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a28da0312733de7b42159de0a3b6be5931683a4c
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Fri Apr 1 22:29:57 2022 +0200
[FLINK-26993] Crude fix
---
.../apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
index 30af82fbe7d..34efb5437c6 100644
---
a/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
+++
b/flink-runtime/src/test/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinatorTest.java
@@ -388,8 +388,9 @@ public class CheckpointCoordinatorTest extends TestLogger {
coordinator.triggerCheckpoint(
true); // enqueue and later see if it gets executed in the
middle of
// receiveAcknowledgeMessage
- while (coordinator.getNumberOfPendingCheckpoints()
- == 0) { // wait for at least 1 request to be fully
processed
+ while (coordinator.getPendingCheckpoints().values().stream()
+ .noneMatch(pc -> pc.getCheckpointStorageLocation() !=
null)) {
+ // wait for at least 1 request to be fully processed
Thread.sleep(10);
}
coordinator.receiveAcknowledgeMessage(
