diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/common/FSBasedSubmarineStorageImpl.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/common/FSBasedSubmarineStorageImpl.java index 767fe78fc35..18815107ffb 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/common/FSBasedSubmarineStorageImpl.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/common/FSBasedSubmarineStorageImpl.java @@ -73,8 +73,7 @@ public void addNewModel(String modelName, String version, private Path getModelInfoPath(String modelName, String version, boolean create) throws IOException { Path modelDir = rdm.getModelDir(modelName, create); - Path modelInfo = new Path(modelDir, version + ".info"); - return modelInfo; + return new Path(modelDir, version + ".info"); } private void serializeMap(FSDataOutputStream fos, Map map) @@ -98,7 +97,6 @@ private void serializeMap(FSDataOutputStream fos, Map map) private Path getJobInfoPath(String jobName, boolean create) throws IOException { Path path = rdm.getJobStagingArea(jobName, create); - Path fileName = new Path(path, "job.info"); - return fileName; + return new Path(path, "job.info"); } } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceJobMonitor.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceJobMonitor.java index 94d30b030f5..fab018a9004 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceJobMonitor.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceJobMonitor.java @@ -40,7 +40,6 @@ public synchronized JobStatus getTrainingJobStatus(String jobName) } Service serviceSpec = this.serviceClient.getStatus(jobName); - JobStatus jobStatus = JobStatusBuilder.fromServiceSpec(serviceSpec); - return jobStatus; + return JobStatusBuilder.fromServiceSpec(serviceSpec); } } diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceUtils.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceUtils.java index d69840abb90..ce3a1eb1b33 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceUtils.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-submarine/src/main/java/org/apache/hadoop/yarn/submarine/runtimes/yarnservice/YarnServiceUtils.java @@ -58,9 +58,7 @@ public static String getDNSName(String serviceName, private static String getDNSNameCommonSuffix(String serviceName, String userName, String domain, int port) { - String commonEndpointSuffix = - "." + serviceName + "." + userName + "." + domain + ":" + port; - return commonEndpointSuffix; + return "." + serviceName + "." + userName + "." + domain + ":" + port; } public static String getTFConfigEnv(String curCommponentName, int nWorkers,