yuluo-yx opened a new issue, #2902: URL: https://github.com/apache/rocketmq-dashboard/issues/2902
### Problem\n builds a single stream pipeline with followed by . Java streams process one element through the complete pipeline before advancing, so each submitted probe is immediately joined and the next probe is not submitted until it finishes.\n\n### Reproduction\nUse two registry entries and a probe function that waits for both calls to start. The second call never starts before the first is released.\n\n### Expected behavior\nIndependent registry entries are submitted before results are joined, bounded by the configured executor.\n\n### Proposed fix\nMaterialize the probe futures first, then join them in input order. Add a latch-based concurrency regression test and retain the existing timeout/saturation tests. -- 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]
