Index: hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java =================================================================== --- hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java (revision 1591508) +++ hbase-it/src/test/java/org/apache/hadoop/hbase/mapreduce/IntegrationTestImportTsv.java (working copy) @@ -47,6 +47,9 @@ import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.Scan; +import org.apache.hadoop.hbase.security.User; +import org.apache.hadoop.hbase.security.UserProvider; +import org.apache.hadoop.hbase.security.token.FsDelegationToken; import org.apache.hadoop.hbase.util.Bytes; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; @@ -267,6 +270,12 @@ try { util.createTable(table, cf); LOG.info("testRunFromOutputCommitter: launching child job."); + if (User.isHBaseSecurityEnabled(conf)) { + FileSystem fs = FileSystem.get(conf); + UserProvider userProvider = UserProvider.instantiate(conf); + FsDelegationToken fsDelegationToken = new FsDelegationToken(userProvider, "renewer"); + fsDelegationToken.acquireDelegationToken(fs); + } TestImportTsv.doMROnTableTest(util, cf, null, args, 1); } catch (Exception e) { throw new IOException("Underlying MapReduce job failed. Aborting commit.", e); @@ -360,6 +369,7 @@ job.setOutputFormatClass(JobLaunchingOutputFormat.class); TextInputFormat.addInputPath(job, inputPath); JobLaunchingOutputFormat.setOutputPath(job, outputPath); + TableMapReduceUtil.initCredentials(job); TableMapReduceUtil.addDependencyJars(job); addTestDependencyJars(job.getConfiguration());