The exception was throwed by :
SecureBulkLoadEndpoint
-- cleanupBulkLoad,

However I checked the /tmp/hbase-staging dir, all the dirs were empty !


and I also wonder to know why we create the staging dir when delete it


public void cleanupBulkLoad(RpcController controller,
               CleanupBulkLoadRequest request,
               RpcCallbackCleanupBulkLoadResponse done) {
  try {
   getAccessController().preCleanupBulkLoad(env);
   fs.delete(createStagingDir(baseStagingDir,
     getActiveUser(),
     env.getRegion().getTableDesc().getTableName(),
     new Path(request.getBulkToken()).getName()),
     true);
   done.run(CleanupBulkLoadResponse.newBuilder().build());
  } catch (IOException e) {
   ResponseConverter.setControllerException(controller, e);
  }
  done.run(null);
 }










原始邮件
发件人:Ted [email protected]
收件人:[email protected][email protected]
发送时间:2014年6月10日(周二) 11:42
主题:Re: permission


Without cleaning staging directory, temp files would pile up on your hdfs, 
right ? Cheers On Mon, Jun 9, 2014 at 8:25 PM, jhaobull [email protected] 
wrote:  thanks!    For this method only does some cleanup work, and I found 
that the data has  been imported to hbase successfully, and now I just ignore 
it, does it ok?      原始邮件  发件人:Ted [email protected]  
收件人:[email protected][email protected]  抄送:[email protected]  
发送时间:2014年6月10日(周二) 10:03  主题:Re: permission    There have been some fixes for 
secure bulk load. The latest of which is  HBASE-11311. Are you able to try out, 
say 0.98.3 which was released today ?  Cheers

Reply via email to