damccorm opened a new pull request, #41121: URL: https://github.com/apache/beam/pull/41121
### Summary In `PostCommit Python Xlang Messaging Direct` (https://github.com/apache/beam/actions/runs/42569166910), `IbmMqJmsIOTest.test_xlang_jms_write_read_queue_client_ack` failed with `AssertionError: 47 != 100`. Root cause: 1. `IbmMqJmsIOTest.produce()` spawned `/opt/mqm/samp/bin/amqsput` 100 separate times in a shell `for` loop (`for i in $(seq 0 99); do echo ... | amqsput; done`), opening and closing 100 sequential MQ client connections (~35-45 seconds). Because `amqsput` reads newline-separated messages from `stdin` in a single connection until EOF or an empty line, piping the loop output into a single `amqsput` invocation publishes all 100 messages in a single connection. 2. `_BaseJmsIOTest._run_streaming_test` only waited `subscriber.join(timeout=20)`, which could expire while the loopback pipeline and `publisher` thread were still running. Increasing `subscriber.join(timeout=60)` provides sufficient headroom under CI load. ### Verification - Triggered `PostCommit Python Xlang Messaging Direct` on branch `fix/xlang-jmsio-it-ibm-mq-timeout`: https://github.com/apache/beam/actions/runs/42655962451 -- 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]
