diff --git a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java index 5bfa8dc021a..c12f7929779 100644 --- a/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java +++ b/hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/SLSRunner.java @@ -732,7 +732,8 @@ private void startAMFromSynthGenerator() throws YarnException, IOException { // creation while ((job = (SynthJob) stjp.getNextJob()) != null) { // only support MapReduce currently - String user = job.getUser(); + String user = job.getUser() == null ? "default" : + job.getUser(); String jobQueue = job.getQueueName(); String oldJobId = job.getJobID().toString(); long jobStartTimeMS = job.getSubmissionTime();