diff --git a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java index fcca3203b..f16ef2f29 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java @@ -30,7 +30,7 @@ import org.apache.log4j.Logger; import java.io.IOException; import java.io.Serializable; -import java.nio.charset.Charset; +import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.HashMap; import java.util.List; @@ -327,7 +327,7 @@ public class HoodieCommitMetadata implements Serializable { public static T fromBytes(byte[] bytes, Class clazz) throws IOException { try { - return fromJsonString(new String(bytes, Charset.forName("utf-8")), clazz); + return fromJsonString(new String(bytes, StandardCharsets.UTF_8), clazz); } catch (Exception e) { throw new IOException("unable to read commit metadata", e); } diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/HoodieAvroUtils.java b/hudi-common/src/main/java/org/apache/hudi/common/util/HoodieAvroUtils.java index 40f907ad8..d030ce810 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/HoodieAvroUtils.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/HoodieAvroUtils.java @@ -40,6 +40,7 @@ import java.io.ByteArrayOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; +import java.nio.charset.StandardCharsets; import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -217,7 +218,7 @@ public class HoodieAvroUtils { ByteArrayOutputStream baos = new ByteArrayOutputStream(); try { OutputStream out = new DeflaterOutputStream(baos); - out.write(text.getBytes("UTF-8")); + out.write(text.getBytes(StandardCharsets.UTF_8)); out.close(); } catch (IOException e) { throw new HoodieIOException("IOException while compressing text " + text, e); @@ -234,7 +235,7 @@ public class HoodieAvroUtils { while ((len = in.read(buffer)) > 0) { baos.write(buffer, 0, len); } - return new String(baos.toByteArray(), "UTF-8"); + return new String(baos.toByteArray(), StandardCharsets.UTF_8); } catch (IOException e) { throw new HoodieIOException("IOException while decompressing text", e); }