rkhachatryan commented on a change in pull request #15466:
URL: https://github.com/apache/flink/pull/15466#discussion_r607709795



##########
File path: 
flink-tests/src/test/java/org/apache/flink/test/checkpointing/UnalignedCheckpointITCase.java
##########
@@ -260,6 +261,10 @@ public UnalignedCheckpointITCase(
                         .setChannelTypes(channelType)
                         .setExpectedFailures(5)
                         .setFailuresAfterSourceFinishes(1)
+                        // prevent test from timing out in case when a 
failover happens concurrently
+                        // with triggering a checkpoint (some execution status 
can change right
+                        // after triggering)
+                        .setCheckpointTimeout(Duration.ofMinutes(1))

Review comment:
       Good point, I'll reduce the timeout and set `TOLERABLE_FAILURE_NUMBER`.
   The test usually takes several seconds, up to 20 on my machine.




-- 
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.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to