diff --git a/common/src/java/org/apache/hadoop/hive/common/io/DigestPrintStream.java b/common/src/java/org/apache/hadoop/hive/common/io/DigestPrintStream.java index 9c1133f7cc..d507eba500 100644 --- a/common/src/java/org/apache/hadoop/hive/common/io/DigestPrintStream.java +++ b/common/src/java/org/apache/hadoop/hive/common/io/DigestPrintStream.java @@ -18,10 +18,9 @@ package org.apache.hadoop.hive.common.io; -import org.apache.commons.codec.binary.Base64; - import java.io.OutputStream; import java.security.MessageDigest; +import java.util.Base64; public class DigestPrintStream extends FetchConverter { @@ -39,7 +38,7 @@ protected void process(String out) { @Override public void processFinal() { - printDirect(new String(Base64.encodeBase64(digest.digest()))); + printDirect(Base64.getEncoder().encodeToString(digest.digest())); digest.reset(); } } diff --git a/common/src/java/org/apache/hadoop/hive/common/io/SortAndDigestPrintStream.java b/common/src/java/org/apache/hadoop/hive/common/io/SortAndDigestPrintStream.java index 68bc8c6041..c0fbd99f08 100644 --- a/common/src/java/org/apache/hadoop/hive/common/io/SortAndDigestPrintStream.java +++ b/common/src/java/org/apache/hadoop/hive/common/io/SortAndDigestPrintStream.java @@ -18,10 +18,9 @@ package org.apache.hadoop.hive.common.io; -import org.apache.commons.codec.binary.Base64; - import java.io.OutputStream; import java.security.MessageDigest; +import java.util.Base64; public class SortAndDigestPrintStream extends SortPrintStream { @@ -39,7 +38,7 @@ public void processFinal() { digest.update(row.getBytes()); printDirect(row); } - printDirect(new String(Base64.encodeBase64(digest.digest()))); + printDirect(Base64.getEncoder().encodeToString(digest.digest())); digest.reset(); } }