This is an automated email from the ASF dual-hosted git repository. pnowojski pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit f4ba4df5824aecfb254591db4958842ae68d707b Author: Piotr Nowojski <[email protected]> AuthorDate: Wed Oct 28 14:11:26 2020 +0100 [hotfix][test] Improve error message in ValidatingCheckpointHandler --- .../flink/streaming/runtime/io/ValidatingCheckpointHandler.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/ValidatingCheckpointHandler.java b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/ValidatingCheckpointHandler.java index 7f4d4fe..f426289 100644 --- a/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/ValidatingCheckpointHandler.java +++ b/flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/ValidatingCheckpointHandler.java @@ -31,6 +31,7 @@ import java.util.List; import java.util.concurrent.CompletableFuture; import java.util.concurrent.Future; +import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; /** @@ -106,8 +107,9 @@ public class ValidatingCheckpointHandler extends AbstractInvokable { CheckpointMetaData checkpointMetaData, CheckpointOptions checkpointOptions, CheckpointMetricsBuilder checkpointMetrics) { - assertTrue("wrong checkpoint id", nextExpectedCheckpointId == -1L || - nextExpectedCheckpointId == checkpointMetaData.getCheckpointId()); + if (nextExpectedCheckpointId != -1L) { + assertEquals(nextExpectedCheckpointId, checkpointMetaData.getCheckpointId()); + } assertTrue(checkpointMetaData.getTimestamp() > 0); nextExpectedCheckpointId = checkpointMetaData.getCheckpointId() + 1;
