varun1729DD commented on PR #24055: URL: https://github.com/apache/flink/pull/24055#issuecomment-1884068345
@tweise Continuing this investigation. I tried reader only and the error did not go away Looking at the logs again I still see the concurrency bug as reported in the original Jira thread. We see the JM (Enumerator) send 'No More Splits event' <img width="934" alt="Screenshot 2024-01-09 at 5 53 55 PM" src="https://github.com/apache/flink/assets/87725200/7b450559-3ea7-447c-bbfa-94ea411efb6d";> And shortly after the TM acts on this event and switches to the next source: <img width="1077" alt="Screenshot 2024-01-09 at 5 52 09 PM" src="https://github.com/apache/flink/assets/87725200/b8511087-eee7-4e0f-9ada-88d861e7cd7f";> What I wonder is what is causing the reader to prematurely close? Synchronization seems to fix it. -- 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]
