From 0f3d4e31f14258a775a2342c4bf534154c97d078 Mon Sep 17 00:00:00 2001 From: Neelesh Srinivas Salian Date: Tue, 18 Oct 2016 17:47:20 -0700 Subject: [PATCH] FLINK-4659: Closed the jassConfStream object to prevent resource leaks --- .../java/org/apache/flink/runtime/security/SecurityContext.java | 1 + 1 file changed, 1 insertion(+) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java b/flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java index 67dd78ccbf7da..f1f9533aaf563 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java @@ -200,6 +200,7 @@ private static void populateSystemSecurityProperties(Configuration configuration Files.copy(jaasConfStream, jaasConfPath, StandardCopyOption.REPLACE_EXISTING); jaasConfFile = jaasConfPath.toFile(); jaasConfFile.deleteOnExit(); + jaasConfStream.close(); } catch (IOException e) { throw new RuntimeException("SASL auth is enabled for ZK but unable to " + "locate pseudo Jaas config provided with Flink", e);