akalash commented on a change in pull request #17354:
URL: https://github.com/apache/flink/pull/17354#discussion_r719499492
##########
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierTrackerTest.java
##########
@@ -607,13 +606,26 @@ public void testTwoLastBarriersOneByOne() throws
Exception {
ValidatingCheckpointHandler validator = new
ValidatingCheckpointHandler();
inputGate = createCheckpointedInputGate(2, sequence, validator);
- for (BufferOrEvent boe : sequence) {
- assertEquals(boe, inputGate.pollNext().get());
- Thread.sleep(10);
- }
+ // start checkpoint 1
+ assertEquals(sequence[0], inputGate.pollNext().get());
+ Thread.sleep(10);
+
+ // start checkpoint 2
+ long start = System.currentTimeMillis();
+ assertEquals(sequence[1], inputGate.pollNext().get());
+ Thread.sleep(1);
Review comment:
We don't need the high sleep time here. I use 1 ms as protection against
zero alignment time. So I just want to have an alignment time of more than zero
and 1 ms is enough
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
