[FLINK-4659] [core] Closed the jassConfStream object to prevent resource leaks
This closes #2665 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/649f9578 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/649f9578 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/649f9578 Branch: refs/heads/master Commit: 649f9578bce56e118ec973218271262286c534a9 Parents: 3e85fc6 Author: Neelesh Srinivas Salian <[email protected]> Authored: Tue Oct 18 17:47:20 2016 -0700 Committer: Stephan Ewen <[email protected]> Committed: Mon Oct 31 19:16:41 2016 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/runtime/security/SecurityContext.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/649f9578/flink-runtime/src/main/java/org/apache/flink/runtime/security/SecurityContext.java ---------------------------------------------------------------------- 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 67dd78c..f1f9533 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 @@ public class SecurityContext { 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);
