This is an automated email from the ASF dual-hosted git repository.
pnowojski pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.15 by this push:
new 3e86cf24fbc [FLINK-26993][tests] Wait until checkpoint was actually
triggered
3e86cf24fbc is described below
commit 3e86cf24fbc430f49692c94cb12df781b2fe82c5
Author: Chesnay Schepler <[email protected]>
AuthorDate: Thu Apr 7 15:25:11 2022 +0200
[FLINK-26993][tests] Wait until checkpoint was actually triggered
(cherry picked from commit a9a7d22b74479510a21cb2237def32c17a1980f0)
---
.../flink/runtime/checkpoint/CheckpointCoordinatorTest.java | 9 +++++++--
1 file changed, 7 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 9d3a87ddd84..a34e7ce4f8d 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
@@ -389,8 +389,13 @@ 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
+ // explicitly check for the checkpoint storage location to
make sure
+ // that the checkpoint was actually triggered
+ // if the checkpoint wasn't triggered yet the acknowledge below
+ // will fail with an error
Thread.sleep(10);
}
coordinator.receiveAcknowledgeMessage(
