stankiewicz opened a new pull request, #40985: URL: https://github.com/apache/beam/pull/40985
Concurrent SolaceIO.Write bundles share pooled JCSMP sessions on a worker. Because publish results were queued per session rather than per bundle, one bundle could drain and emit another bundle's ACK during finishBundle, leaving the owning bundle to time out waiting for a result that had already been removed. Give each bundle its own publish-results queue and pass that queue inside the JCSMP message correlation key so the callback handler delivers ACKs and NACKs directly to the bundle that published the message. Track in-flight message IDs with a multiset so duplicate IDs in a single bundle wait for all publications. Fixes #40984 -- 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]
