mjsax commented on code in PR #20693:
URL: https://github.com/apache/kafka/pull/20693#discussion_r2505399958
##########
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamTaskTest.java:
##########
@@ -1625,15 +1625,15 @@ public void shouldLogNotReadyWhenStaleAfterThreshold()
throws Exception {
final long initialTime = time.milliseconds();
task.setLastNotReadyLogTime(initialTime - 100_000L);
- // Advance time by approximately 5 seconds
- long newTime = time.milliseconds() + 5_000L;
+ // Advance time by 19 seconds
+ long newTime = time.milliseconds() + 19_000L;
Review Comment:
Seems we could make this `19_999` to have a most tight test, which verifies
the exact ms cut of point?
--
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]
