ammu20-dev commented on code in PR #25656: URL: https://github.com/apache/flink/pull/25656#discussion_r1852573652
########## flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableEnvironmentImpl.java: ########## @@ -1029,6 +1029,8 @@ private TableResultInternal executeInternal( defaultJobName, jobStatusHookList); try { + ClassLoader userClassLoader = Thread.currentThread().getContextClassLoader(); Review Comment: Added comments on the need for this change. The latest FLIP implementation to introduce a stream graph based job submission moved the StreamGraph module to flink runtime and changed the job submission logic by directly submitting a StreamGraph to the job manager. Ref FLIP: https://cwiki.apache.org/confluence/display/FLINK/FLIP-468%3A+Introducing+StreamGraph-Based+Job+Submission Related JIRA: https://issues.apache.org/jira/browse/FLINK-36065 As a result of these changes this issue seems to be fixed for flink v2 as I was not able to reproduce it with the latest main. Hence limiting this particular change to 1.20 versions. -- 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: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org