HBASE-15291 Revert due to the bug Haitao discovered
This commit is contained in:
parent
dc44943666
commit
edc5ab5af9
|
@ -292,16 +292,6 @@ public class SecureBulkLoadEndpoint extends SecureBulkLoadService
|
||||||
new SecureBulkLoadListener(fs, bulkToken, conf));
|
new SecureBulkLoadListener(fs, bulkToken, conf));
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
LOG.error("Failed to complete bulk load", e);
|
LOG.error("Failed to complete bulk load", e);
|
||||||
} finally {
|
|
||||||
if (fs != null) {
|
|
||||||
try {
|
|
||||||
if(!UserGroupInformation.getCurrentUser().equals(ugi)) {
|
|
||||||
FileSystem.closeAllForUGI(ugi);
|
|
||||||
}
|
|
||||||
} catch (IOException e) {
|
|
||||||
LOG.error("Failed to close FileSystem for " + ugi.getUserName(), e);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue