eugenegujing commented on PR #6724:
URL: https://github.com/apache/texera/pull/6724#issuecomment-5052724109

   > Can you provide a real workflow that can reproduce this bug?
   
   Here's a real repro on main (screenshot). The workflow is scan → sort → 
Python UDF. Sort is blocking, so the UDF runs in a second region and reads its 
input from storage through the materialization reader threads. I clicked pause 
right when the second region started, before the readers sent anything. Their 
channel was registered after disable_data, so it came up enabled, and the 
paused worker went on to consume the whole input and call complete(), which 
threw InvalidTransitionException: Cannot transit from PAUSED to COMPLETED and 
killed the DP thread. The heartbeat thread is still alive, so resume never gets 
processed and the execution stays stuck in "Resuming" with no error shown 
anywhere. With the fix, the channel starts disabled and the same run finishes 
normally after resume.
   <img width="1157" height="807" alt="Screenshot 2026-07-22 at 4 08 24 PM" 
src="https://github.com/user-attachments/assets/0c74d841-970b-408b-812d-239e7f18958e";
 />
   


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

Reply via email to