Index: ql/src/java/org/apache/hadoop/hive/ql/io/merge/MergeFileTask.java IDEA additional info: Subsystem: com.intellij.openapi.diff.impl.patch.CharsetEP <+>UTF-8 =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/io/merge/MergeFileTask.java (revision 5d69d71271bf3d015a20a2820087104e1994025d) +++ ql/src/java/org/apache/hadoop/hive/ql/io/merge/MergeFileTask.java (date 1592360982000) @@ -84,7 +84,7 @@ boolean ctxCreated = false; RunningJob rj = null; int returnVal = 0; - + JobClient jc = null; try { if (ctx == null) { ctx = new Context(job); @@ -140,7 +140,7 @@ } // submit the job - JobClient jc = new JobClient(job); + jc = new JobClient(job); String addedJars = Utilities.getResourceFiles(job, SessionState.ResourceType.JAR); @@ -192,6 +192,9 @@ } } } + if (jc!=null) { + jc.close(); + } } catch (Exception e) { // jobClose needs to execute successfully otherwise fail task LOG.warn("Job close failed ",e);