flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [3/4] flink git commit: [FLINK-4659] [core] Closed the jassConfStream object to prevent resource leaks
Date Mon, 31 Oct 2016 18:17:11 GMT
[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 <nsalian@cloudera.com>
Authored: Tue Oct 18 17:47:20 2016 -0700
Committer: Stephan Ewen <sewen@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);


Mime
View raw message