HBASE-15291 Revert due to race condition resulting in closed FileSystem error
This commit is contained in:
parent
65834a1ced
commit
519f87fc2b
|
@ -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;
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue