[FLINK-22000][io] Set a default character set in InputStreamReader

Author: dbgp2021

flink-external-resources/flink-external-resource-gpu/src/main/java/org/apache/flink/externalresource/gpu/GPUDriver.java

@@ -36,6 +36,7 @@
 import java.io.File;
 import java.io.FileNotFoundException;
 import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.util.Arrays;
@@ -133,9 +134,13 @@ private String executeDiscoveryScript(File discoveryScript, long gpuAmount, Stri
         final String cmd = discoveryScript.getAbsolutePath() + " " + gpuAmount + " " + args;
         final Process process = Runtime.getRuntime().exec(cmd);
         try (final BufferedReader stdoutReader =
-                        new BufferedReader(new InputStreamReader(process.getInputStream()));
+                        new BufferedReader(
+                                new InputStreamReader(
+                                        process.getInputStream(), StandardCharsets.UTF_8));
                 final BufferedReader stderrReader =
-                        new BufferedReader(new InputStreamReader(process.getErrorStream()))) {
+                        new BufferedReader(
+                                new InputStreamReader(
+                                        process.getErrorStream(), StandardCharsets.UTF_8))) {
             final boolean hasProcessTerminated =
                     process.waitFor(DISCOVERY_SCRIPT_TIMEOUT_MS, TimeUnit.MILLISECONDS);
             if (!hasProcessTerminated) {

flink-python/src/main/java/org/apache/flink/client/python/PythonDriver.java

@@ -30,6 +30,7 @@
 import java.io.BufferedReader;
 import java.io.File;
 import java.io.InputStreamReader;
+import java.nio.charset.StandardCharsets;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.UUID;
@@ -101,7 +102,9 @@ public static void main(String[] args) throws Throwable {
             Runtime.getRuntime().addShutdownHook(shutdownHook);
 
             BufferedReader in =
-                    new BufferedReader(new InputStreamReader(pythonProcess.getInputStream()));
+                    new BufferedReader(
+                            new InputStreamReader(
+                                    pythonProcess.getInputStream(), StandardCharsets.UTF_8));
             LOG.info(
                     "--------------------------- Python Process Started --------------------------");
             // print the python process output to stdout and log file

flink-runtime/src/main/java/org/apache/flink/runtime/util/Hardware.java

@@ -31,6 +31,7 @@
 import java.lang.management.OperatingSystemMXBean;
 import java.lang.reflect.InvocationTargetException;
 import java.lang.reflect.Method;
+import java.nio.charset.StandardCharsets;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
@@ -154,7 +155,9 @@ private static long getSizeOfPhysicalMemoryForMac() {
         try {
             Process proc = Runtime.getRuntime().exec("sysctl hw.memsize");
 
-            bi = new BufferedReader(new InputStreamReader(proc.getInputStream()));
+            bi =
+                    new BufferedReader(
+                            new InputStreamReader(proc.getInputStream(), StandardCharsets.UTF_8));
 
             String line;
             while ((line = bi.readLine()) != null) {
@@ -191,7 +194,9 @@ private static long getSizeOfPhysicalMemoryForFreeBSD() {
         try {
             Process proc = Runtime.getRuntime().exec("sysctl hw.physmem");
 
-            bi = new BufferedReader(new InputStreamReader(proc.getInputStream()));
+            bi =
+                    new BufferedReader(
+                            new InputStreamReader(proc.getInputStream(), StandardCharsets.UTF_8));
 
             String line;
             while ((line = bi.readLine()) != null) {
@@ -234,7 +239,9 @@ private static long getSizeOfPhysicalMemoryForWindows() {
         try {
             Process proc = Runtime.getRuntime().exec("wmic memorychip get capacity");
 
-            bi = new BufferedReader(new InputStreamReader(proc.getInputStream()));
+            bi =
+                    new BufferedReader(
+                            new InputStreamReader(proc.getInputStream(), StandardCharsets.UTF_8));
 
             String line = bi.readLine();
             if (line == null) {