You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2016/10/31 18:17:11 UTC
[3/4] flink git commit: [FLINK-4659] [core] Closed the jassConfStream
object to prevent resource leaks
[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 <ns...@cloudera.com>
Authored: Tue Oct 18 17:47:20 2016 -0700
Committer: Stephan Ewen <se...@apache.org>
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);