You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fh...@apache.org on 2015/10/26 22:50:50 UTC
[7/8] flink git commit: [FLINK-2827] Close FileInputStream through
try-with-resources to avoid unused open stream.
[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 <sa...@gmail.com>
Authored: Tue Oct 20 19:28:31 2015 +0200
Committer: Fabian Hueske <fh...@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);
}