|
@@ -119,7 +119,9 @@ public class MiniMRYarnCluster extends MiniYARNCluster {
|
|
@Override
|
|
@Override
|
|
public void serviceInit(Configuration conf) throws Exception {
|
|
public void serviceInit(Configuration conf) throws Exception {
|
|
conf.set(MRConfig.FRAMEWORK_NAME, MRConfig.YARN_FRAMEWORK_NAME);
|
|
conf.set(MRConfig.FRAMEWORK_NAME, MRConfig.YARN_FRAMEWORK_NAME);
|
|
- if (conf.get(MRJobConfig.MR_AM_STAGING_DIR) == null) {
|
|
|
|
|
|
+ String stagingDir = conf.get(MRJobConfig.MR_AM_STAGING_DIR);
|
|
|
|
+ if (stagingDir == null ||
|
|
|
|
+ stagingDir.equals(MRJobConfig.DEFAULT_MR_AM_STAGING_DIR)) {
|
|
conf.set(MRJobConfig.MR_AM_STAGING_DIR, new File(getTestWorkDir(),
|
|
conf.set(MRJobConfig.MR_AM_STAGING_DIR, new File(getTestWorkDir(),
|
|
"apps_staging_dir/").getAbsolutePath());
|
|
"apps_staging_dir/").getAbsolutePath());
|
|
}
|
|
}
|