wForget opened a new pull request, #7646:
URL: https://github.com/apache/kyuubi/pull/7646

   ### Why are the changes needed?
   
   Closes #7644.
   
   In Flink YARN application mode, Kyuubi retains Flink's original application 
job ID list for the bootstrap job and uses a thread-safe copy for subsequent 
jobs. However, the list was selected based on whether the original list was 
empty.
   
   Because the engine frontend could become available before bootstrap 
completed, the bootstrap query and a client query could both receive the 
original non-thread-safe `ArrayList`. Concurrent additions could then cause an 
`ArrayIndexOutOfBoundsException`.
   
   This patch atomically reserves the original list for one bootstrap executor 
and completes bootstrap before exposing the engine frontend.
   
   ### How was this patch tested?
   
   Added `EmbeddedExecutorFactorySuite` to verify that the original Flink 
application job ID list is returned to only one executor and subsequent 
executors use the thread-safe collection.
   
   ### Was this patch assisted by generative AI tooling?
   
   Assisted-by: Codex with GPT-5


-- 
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]

Reply via email to