You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by uc...@apache.org on 2015/08/11 22:44:57 UTC
flink git commit: [FLINK-2511] [runtime] Make sure to close
FileInputStream in FlinkZooKeeperQuorumPeer
Repository: flink
Updated Branches:
refs/heads/master 10ce2e2d0 -> d8d074809
[FLINK-2511] [runtime] Make sure to close FileInputStream in FlinkZooKeeperQuorumPeer
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d8d07480
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d8d07480
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d8d07480
Branch: refs/heads/master
Commit: d8d074809e72ece8593ae4d3d17b9ec4febb1fb2
Parents: 10ce2e2
Author: Ufuk Celebi <uc...@apache.org>
Authored: Tue Aug 11 22:40:19 2015 +0200
Committer: Ufuk Celebi <uc...@apache.org>
Committed: Tue Aug 11 22:40:19 2015 +0200
----------------------------------------------------------------------
.../flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d8d07480/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java b/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
index c9d3ec4..a0ce88c 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/zookeeper/FlinkZooKeeperQuorumPeer.java
@@ -79,8 +79,9 @@ public class FlinkZooKeeperQuorumPeer {
Properties zkProps = new Properties();
- InputStream inStream = new FileInputStream(new File(zkConfigFile));
- zkProps.load(inStream);
+ try (InputStream inStream = new FileInputStream(new File(zkConfigFile))) {
+ zkProps.load(inStream);
+ }
LOG.info("Configuration: " + zkProps);