wenjin272 commented on issue #306: URL: https://github.com/apache/flink-agents/issues/306#issuecomment-3506668906
@bydeath, thanks for your detailed analysis. Actually, the JIRA issue [FLINK-38585](https://issues.apache.org/jira/browse/FLINK-38585) is discovered when @Sxnan try to submit a flink-agents job to a k8s cluster. And after offline discussion and debugging, @bgeng777 fixed this issue in PEMJA and created this Jira issue. If I understand correctly, the thread mode of pyflink is just based on pemja, meaning that using PEMJA implies the use of thread mode, so the behavior flink-agents directly use pemja is just like pyflink thread mode. I indeed cann't determine whether this is the same issue described in the Jira issue. @GreatEugenius has already reproduced this bug on the Yarn cluster and is currently verifying whether it is the same issue. We can wait for his analysis. Thank you again for your detailed description and analysis. -- 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]
