You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/08/28 09:12:52 UTC
[flink] branch release-1.9 updated: [FLINK-13807][tests] Use UTF-8
charset in TestBaseUtils.getResultReader
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 603c128 [FLINK-13807][tests] Use UTF-8 charset in TestBaseUtils.getResultReader
603c128 is described below
commit 603c128c364b8f6bb20dce5ce2708b614b284a99
Author: tison <wa...@gmail.com>
AuthorDate: Wed Aug 28 17:11:36 2019 +0800
[FLINK-13807][tests] Use UTF-8 charset in TestBaseUtils.getResultReader
---
.../src/main/java/org/apache/flink/test/util/TestBaseUtils.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
index 77818bc..77b4148 100644
--- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
+++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/TestBaseUtils.java
@@ -37,14 +37,15 @@ import java.io.BufferedInputStream;
import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
-import java.io.FileReader;
import java.io.FilenameFilter;
import java.io.IOException;
import java.io.InputStream;
+import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URI;
import java.net.URISyntaxException;
import java.net.URL;
+import java.nio.charset.StandardCharsets;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
@@ -138,7 +139,7 @@ public class TestBaseUtils extends TestLogger {
BufferedReader[] readers = new BufferedReader[files.length];
for (int i = 0; i < files.length; i++) {
- readers[i] = new BufferedReader(new FileReader(files[i]));
+ readers[i] = new BufferedReader(new InputStreamReader(new FileInputStream(files[i]), StandardCharsets.UTF_8));
}
return readers;
}