migrate CliFrontend to PackagedProgram#close

apache · Jan 29, 2021 · c833d99 · c833d99
1 parent ce3c983
commit c833d99
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 7 deletions.
diff --git a/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java b/flink-clients/src/main/java/org/apache/flink/client/cli/CliFrontend.java
@@ -242,12 +242,8 @@ protected void run(String[] args) throws Exception {
 
         LOG.debug("Effective executor configuration: {}", effectiveConfiguration);
 
-        final PackagedProgram program = getPackagedProgram(programOptions, effectiveConfiguration);
-
-        try {
+        try (PackagedProgram program = getPackagedProgram(programOptions, effectiveConfiguration)) {
             executeProgram(effectiveConfiguration, program);
-        } finally {
-            program.deleteExtractedLibraries();
         }
     }
 
@@ -387,7 +383,7 @@ protected void info(String[] args) throws Exception {
             }
         } finally {
             if (program != null) {
-                program.deleteExtractedLibraries();
+                program.close();
             }
         }
     }

diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java b/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java
@@ -295,7 +295,7 @@ public static List<URL> getJobJarAndDependencies(
     }
 
     /** Deletes all temporary files created for contained packaged libraries. */
-    public void deleteExtractedLibraries() {
+    private void deleteExtractedLibraries() {
         deleteExtractedLibraries(this.extractedTempLibraries);
         this.extractedTempLibraries.clear();
     }