Abacn commented on code in PR #34181:
URL: https://github.com/apache/beam/pull/34181#discussion_r1981638901
##########
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:
this test adds 1 million futures, sounds a bad choice in terms of unit
testing. Would reduce the load of the test help here?
--
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]
