Skip to content

Commit 937ac1f

Browse files
committed
Loose withCloseTimeout to fix flaky integration test
1 parent aa7f7e8 commit 937ac1f

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

  • sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms

sdks/java/io/jms/src/test/java/org/apache/beam/sdk/io/jms/JmsIOIT.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -304,9 +304,9 @@ private PipelineResult readMessages(JmsIO.AcknowledgeMode acknowledgeMode, Strin
304304
JmsIO.Read<String> jmsIORead =
305305
JmsIO.<String>readMessage()
306306
.withAcknowledgeMode(acknowledgeMode)
307-
// Decrease withCloseTimeout to be smaller than pipeline runtime. Direct runner randomly
307+
// Decrease withCloseTimeout to be smaller than pipeline timeout. Direct runner randomly
308308
// closes reader causing cached pending consumer hanging until closeTimeout
309-
.withCloseTimeout(Duration.standardSeconds(5));
309+
.withCloseTimeout(Duration.standardSeconds(10));
310310
if (pipelineRead.getOptions().as(JmsIOITOptions.class).getUseConnectionFactoryProviderFn()) {
311311
jmsIORead =
312312
jmsIORead.withConnectionFactoryProviderFn(

0 commit comments

Comments
 (0)