[FLINK-2827] Close FileInputStream through try-with-resources to avoid unused open stream.
This closes #1276 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/6a8e90b3 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6a8e90b3 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6a8e90b3 Branch: refs/heads/master Commit: 6a8e90b3621bb96304b325a4ae8f7f5575ec909a Parents: 7265d81 Author: Saumitra Shahapure <saumitra.offic...@gmail.com> Authored: Tue Oct 20 19:28:31 2015 +0200 Committer: Fabian Hueske <fhue...@apache.org> Committed: Mon Oct 26 20:05:03 2015 +0100 ---------------------------------------------------------------------- .../apache/flink/streaming/connectors/twitter/TwitterSource.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/6a8e90b3/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java ---------------------------------------------------------------------- diff --git a/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java b/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java index bad0f8c..d290f98 100644 --- a/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java +++ b/flink-streaming-connectors/flink-connector-twitter/src/main/java/org/apache/flink/streaming/connectors/twitter/TwitterSource.java @@ -133,10 +133,8 @@ public class TwitterSource extends RichSourceFunction<String> { private Properties loadAuthenticationProperties() { Properties properties = new Properties(); - try { - InputStream input = new FileInputStream(authPath); + try (InputStream input = new FileInputStream(authPath)) { properties.load(input); - input.close(); } catch (Exception e) { throw new RuntimeException("Cannot open .properties file: " + authPath, e); }
