|
@@ -151,6 +151,8 @@ public class TestMRAppMaster {
|
|
|
String userName = "TestAppMasterUser";
|
|
|
JobConf conf = new JobConf();
|
|
|
conf.set(MRJobConfig.MR_AM_STAGING_DIR, stagingDir);
|
|
|
+ conf.setInt(org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter.
|
|
|
+ FILEOUTPUTCOMMITTER_ALGORITHM_VERSION, 1);
|
|
|
ApplicationAttemptId applicationAttemptId = ConverterUtils
|
|
|
.toApplicationAttemptId(applicationAttemptIdStr);
|
|
|
JobId jobId = TypeConverter.toYarn(
|