Skip to content

Commit 357862a

Browse files
authored
[runners-flink] Bump FlinkRequiresStableInputTest timeout to 120s (#38273)
The four portable-execution test methods in FlinkRequiresStableInputTest were declared with `@Test(timeout = 30_000)`, which is consistently exceeded under CI load and currently causes testParDoRequiresStableInputPortable to fail TestTimedOutException at FlinkRequiresStableInputTest.java:190 (the 1-second poll loop in executePipeline) on every recent beam_PreCommit_Java run on master. All four sibling portable-pipeline tests in the same package (PortableExecutionTest, PortableTimersExecutionTest, PortableStateExecutionTest, ReadSourcePortableTest) already use `@Test(timeout = 120_000)`. This test is doing strictly more work (deliberate failure -> checkpoint -> restore -> re-execute -> DONE) yet had a 4x tighter budget, which matches the "Jenkins under high load" diagnosis from #21333. Aligning the timeout with the rest of the portable Flink test suite.
1 parent 3ea73d2 commit 357862a

1 file changed

Lines changed: 4 additions & 4 deletions

File tree

runners/flink/src/test/java/org/apache/beam/runners/flink/FlinkRequiresStableInputTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -103,22 +103,22 @@ public static void setup() {
103103
* <p>A Savepoint is taken until the desired state in the operators has been reached. We then
104104
* restore the savepoint to check if we produce impotent results.
105105
*/
106-
@Test(timeout = 30_000)
106+
@Test(timeout = 120_000)
107107
public void testParDoRequiresStableInput() throws Exception {
108108
runTest(false);
109109
}
110110

111-
@Test(timeout = 30_000)
111+
@Test(timeout = 120_000)
112112
public void testParDoRequiresStableInputPortable() throws Exception {
113113
runTest(true);
114114
}
115115

116-
@Test(timeout = 30_000)
116+
@Test(timeout = 120_000)
117117
public void testParDoRequiresStableInputStateful() throws Exception {
118118
testParDoRequiresStableInputStateful(false);
119119
}
120120

121-
@Test(timeout = 30_000)
121+
@Test(timeout = 120_000)
122122
public void testParDoRequiresStableInputStatefulPortable() throws Exception {
123123
testParDoRequiresStableInputStateful(true);
124124
}

0 commit comments

Comments
 (0)