Browse Source

YARN-6719. Fix findbugs warnings in SLSCapacityScheduler.java. Contributed by Akira Ajisaka.

Naganarasimha 8 years ago
parent
commit
582bdfd423

+ 8 - 3
hadoop-tools/hadoop-sls/src/main/java/org/apache/hadoop/yarn/sls/scheduler/SLSCapacityScheduler.java

@@ -84,8 +84,10 @@ import org.apache.log4j.Logger;
 
 
 import java.io.BufferedWriter;
 import java.io.BufferedWriter;
 import java.io.File;
 import java.io.File;
-import java.io.FileWriter;
+import java.io.FileOutputStream;
 import java.io.IOException;
 import java.io.IOException;
+import java.io.OutputStreamWriter;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.HashSet;
@@ -488,7 +490,8 @@ public class SLSCapacityScheduler extends CapacityScheduler implements
 
 
     // application running information
     // application running information
     jobRuntimeLogBW = new BufferedWriter(
     jobRuntimeLogBW = new BufferedWriter(
-            new FileWriter(metricsOutputDir + "/jobruntime.csv"));
+        new OutputStreamWriter(new FileOutputStream(
+            metricsOutputDir + "/jobruntime.csv"), StandardCharsets.UTF_8));
     jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
     jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
             "simulate_start_time,simulate_end_time" + EOL);
             "simulate_start_time,simulate_end_time" + EOL);
     jobRuntimeLogBW.flush();
     jobRuntimeLogBW.flush();
@@ -693,7 +696,9 @@ public class SLSCapacityScheduler extends CapacityScheduler implements
     public MetricsLogRunnable() {
     public MetricsLogRunnable() {
       try {
       try {
         metricsLogBW = new BufferedWriter(
         metricsLogBW = new BufferedWriter(
-                new FileWriter(metricsOutputDir + "/realtimetrack.json"));
+            new OutputStreamWriter(new FileOutputStream(
+                metricsOutputDir + "/realtimetrack.json"),
+                StandardCharsets.UTF_8));
         metricsLogBW.write("[");
         metricsLogBW.write("[");
       } catch (IOException e) {
       } catch (IOException e) {
         e.printStackTrace();
         e.printStackTrace();