lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[CLEAN] replace utf-8 constant with StandardCharsets.UTF_8

Browse Source
This commit is contained in:
lamber-ken
2020-01-08 11:12:10 +08:00
committed by n3nash
parent b95367d82a
commit e103165083
2 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java
View File

@@ -30,7 +30,7 @@ import org.apache.log4j.Logger;
import java.io.IOException; import java.io.IOException;
import java.io.Serializable; import java.io.Serializable;
import java.nio.charset.Charset; import java.nio.charset.StandardCharsets;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List; import java.util.List;
@@ -327,7 +327,7 @@ public class HoodieCommitMetadata implements Serializable {
public static <T> T fromBytes(byte[] bytes, Class<T> clazz) throws IOException { public static <T> T fromBytes(byte[] bytes, Class<T> clazz) throws IOException {
try { try {
return fromJsonString(new String(bytes, Charset.forName("utf-8")), clazz); return fromJsonString(new String(bytes, StandardCharsets.UTF_8), clazz);
} catch (Exception e) { } catch (Exception e) {
throw new IOException("unable to read commit metadata", e); throw new IOException("unable to read commit metadata", e);
} }

5
hudi-common/src/main/java/org/apache/hudi/common/util/HoodieAvroUtils.java
View File

@@ -40,6 +40,7 @@ import java.io.ByteArrayOutputStream;
import java.io.IOException; import java.io.IOException;
import java.io.InputStream; import java.io.InputStream;
import java.io.OutputStream; import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays; import java.util.Arrays;
import java.util.List; import java.util.List;
@@ -217,7 +218,7 @@ public class HoodieAvroUtils {
ByteArrayOutputStream baos = new ByteArrayOutputStream(); ByteArrayOutputStream baos = new ByteArrayOutputStream();
try { try {
OutputStream out = new DeflaterOutputStream(baos); OutputStream out = new DeflaterOutputStream(baos);
out.write(text.getBytes("UTF-8")); out.write(text.getBytes(StandardCharsets.UTF_8));
out.close(); out.close();
} catch (IOException e) { } catch (IOException e) {
throw new HoodieIOException("IOException while compressing text " + text, e); throw new HoodieIOException("IOException while compressing text " + text, e);
@@ -234,7 +235,7 @@ public class HoodieAvroUtils {
while ((len = in.read(buffer)) > 0) { while ((len = in.read(buffer)) > 0) {
baos.write(buffer, 0, len); baos.write(buffer, 0, len);
} }
return new String(baos.toByteArray(), "UTF-8"); return new String(baos.toByteArray(), StandardCharsets.UTF_8);
} catch (IOException e) { } catch (IOException e) {
throw new HoodieIOException("IOException while decompressing text", e); throw new HoodieIOException("IOException while decompressing text", e);
} }