Amar3tto commented on code in PR #34181:
URL: https://github.com/apache/beam/pull/34181#discussion_r1983362000
##########
runners/flink/src/test/java/org/apache/beam/runners/flink/translation/wrappers/streaming/io/source/unbounded/FlinkUnboundedSourceReaderTest.java:
##########
@@ -92,7 +92,7 @@ public void testSnapshotStateAndRestore() throws Exception {
* This is a concurrency correctness test. It verifies that the main thread
is always waken up by
* the alarm runner executed in the executor thread.
*/
- @Test(timeout = 30000L)
+ @Test(timeout = 60000L)
public void testIsAvailableAlwaysWakenUp() throws Exception {
final int numFuturesRequired = 1_000_000;
Review Comment:
Decreased to 1000.
I'd like to leave a 60 second timeout just in case.
--
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]
