Skip to content

Commit 582bdfd

Browse files
committed
YARN-6719. Fix findbugs warnings in SLSCapacityScheduler.java. Contributed by Akira Ajisaka.
1 parent e47ec94 commit 582bdfd

1 file changed

Lines changed: 8 additions & 3 deletions

File tree

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

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -84,8 +84,10 @@
8484

8585
import java.io.BufferedWriter;
8686
import java.io.File;
87-
import java.io.FileWriter;
87+
import java.io.FileOutputStream;
8888
import java.io.IOException;
89+
import java.io.OutputStreamWriter;
90+
import java.nio.charset.StandardCharsets;
8991
import java.util.ArrayList;
9092
import java.util.HashMap;
9193
import java.util.HashSet;
@@ -488,7 +490,8 @@ private void initMetrics() throws Exception {
488490

489491
// application running information
490492
jobRuntimeLogBW = new BufferedWriter(
491-
new FileWriter(metricsOutputDir + "/jobruntime.csv"));
493+
new OutputStreamWriter(new FileOutputStream(
494+
metricsOutputDir + "/jobruntime.csv"), StandardCharsets.UTF_8));
492495
jobRuntimeLogBW.write("JobID,real_start_time,real_end_time," +
493496
"simulate_start_time,simulate_end_time" + EOL);
494497
jobRuntimeLogBW.flush();
@@ -693,7 +696,9 @@ class MetricsLogRunnable implements Runnable {
693696
public MetricsLogRunnable() {
694697
try {
695698
metricsLogBW = new BufferedWriter(
696-
new FileWriter(metricsOutputDir + "/realtimetrack.json"));
699+
new OutputStreamWriter(new FileOutputStream(
700+
metricsOutputDir + "/realtimetrack.json"),
701+
StandardCharsets.UTF_8));
697702
metricsLogBW.write("[");
698703
} catch (IOException e) {
699704
e.printStackTrace();

0 commit comments

Comments
 (0)