Repository: hbase Updated Branches: refs/heads/master 65834a1ce -> 519f87fc2
HBASE-15291 Revert due to race condition resulting in closed FileSystem error Project: http://git-wip-us.apache.org/repos/asf/hbase/repo Commit: http://git-wip-us.apache.org/repos/asf/hbase/commit/519f87fc Tree: http://git-wip-us.apache.org/repos/asf/hbase/tree/519f87fc Diff: http://git-wip-us.apache.org/repos/asf/hbase/diff/519f87fc Branch: refs/heads/master Commit: 519f87fc2bde21031f95cbb6cab031eccc4ac2e1 Parents: 65834a1 Author: Jerry He <jerry...@apache.org> Authored: Thu Jul 21 18:48:56 2016 -0700 Committer: Jerry He <jerry...@apache.org> Committed: Thu Jul 21 18:51:47 2016 -0700 ---------------------------------------------------------------------- .../hadoop/hbase/regionserver/SecureBulkLoadManager.java | 10 ---------- 1 file changed, 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hbase/blob/519f87fc/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java ---------------------------------------------------------------------- diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java index 7a43c5d..9f53ac5 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/regionserver/SecureBulkLoadManager.java @@ -250,16 +250,6 @@ public class SecureBulkLoadManager { new SecureBulkLoadListener(fs, bulkToken, conf)); } catch (Exception e) { LOG.error("Failed to complete bulk load", e); - } finally { - if (fs != null) { - try { - if (!UserGroupInformation.getLoginUser().equals(ugi)) { - FileSystem.closeAllForUGI(ugi); - } - } catch (IOException e) { - LOG.error("Failed to close FileSystem for " + ugi.getUserName(), e); - } - } } return false; }
