Gabriel39 opened a new pull request, #68642: URL: https://github.com/apache/doris/pull/68642
## Problem With parallel result sinks, Nereids publishes one Flight endpoint per pipeline instance even though instances on the same backend share a query-id result buffer. Six result backends with eight instances each therefore publish 48 endpoints for only six independent result streams. ## Fix Publish one endpoint per backend in query-id mode, preserving first-seen order and the existing instance-id behavior in non-parallel mode. Backend IDs distinguish result owners even when Flight addresses are shared. Add five FE unit tests and a Flight regression covering unique tickets and complete results for sequential/concurrent consumption with parallel result sinks enabled and disabled. ## Validation - Reproduced the original bug with three failing unit tests (including 48 endpoints instead of 6); all five tests pass after the fix. - Compiled the changed FE class and tests with `javac --release 8` against cached dependencies. - FE Checkstyle and Groovy regression compilation checked locally. - Full cluster regression is pending CI. -- 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] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
