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 2015/03/30 14:14:58 UTC
[4/4] flink git commit: [FLINK-1774] Remove the redundant code in
try{} block.
[FLINK-1774] Remove the redundant code in try{} block.
This closes #522
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c89c657a
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c89c657a
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c89c657a
Branch: refs/heads/master
Commit: c89c657ae16bbe89da54669a234713a3811813ee
Parents: fb3f3ee
Author: hongsibao <ho...@huawei.com>
Authored: Tue Mar 24 00:23:57 2015 +0800
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Mar 30 13:01:34 2015 +0200
----------------------------------------------------------------------
.../java/org/apache/flink/runtime/blob/BlobServerConnection.java | 2 --
1 file changed, 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c89c657a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java
index d9facfc..b2f11db 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/blob/BlobServerConnection.java
@@ -308,8 +308,6 @@ class BlobServerConnection extends Thread {
}
}
- fos.close();
- fos = null;
if (contentAddressable == NAME_ADDRESSABLE) {
File storageFile = this.blobServer.getStorageLocation(jobID, key);