MartijnVisser commented on code in PR #29473:
URL: https://github.com/apache/flink/pull/29473#discussion_r4359356336
##########
flink-clients/src/main/java/org/apache/flink/client/deployment/application/PackagedProgramApplication.java:
##########
@@ -368,6 +378,20 @@ public void cancel() {
public void dispose() {
isDisposing = true;
cancelFutures();
+ closeProgram();
Review Comment:
In application mode, ApplicationDispatcherGatewayServiceFactory hands this
same program to a new application on every leadership grant. Closing it on
dispose means the next leader runs main with a closed classloader and deleted
lib/ jars. I reproduced that locally.
--
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]
