[rocketmq-flink] 28/33: Build pass jdk9+

[duhengforever]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git

commit 465c60acdc38db00c1fa732c2fa38736a0d92e2b
Author: vongosling <vongosl...@apache.org>
AuthorDate: Tue Aug 17 10:37:14 2021 +0800

    Build pass jdk9+
---
 .../org/apache/rocketmq/flink/source/util/StringSerializer.java    | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)

diff --git 
a/src/main/java/org/apache/rocketmq/flink/source/util/StringSerializer.java 
b/src/main/java/org/apache/rocketmq/flink/source/util/StringSerializer.java
index b468ac9..c0a67b8 100644
--- a/src/main/java/org/apache/rocketmq/flink/source/util/StringSerializer.java
+++ b/src/main/java/org/apache/rocketmq/flink/source/util/StringSerializer.java
@@ -17,6 +17,7 @@
 
 package org.apache.rocketmq.flink.source.util;
 
+import java.util.Base64;
 import org.apache.flink.table.data.DecimalData;
 import org.apache.flink.table.data.binary.BinaryStringData;
 import org.apache.flink.table.data.util.DataFormatConverters;
@@ -24,8 +25,6 @@ import 
org.apache.flink.table.data.util.DataFormatConverters.TimestampConverter;
 import org.apache.flink.table.types.DataType;
 import org.apache.flink.table.types.logical.DecimalType;
 
-import sun.misc.BASE64Decoder;
-
 import java.math.BigDecimal;
 import java.math.BigInteger;
 import java.sql.Date;
@@ -37,7 +36,7 @@ import java.util.Set;
 public class StringSerializer {
 
     public static TimestampConverter timestampConverter = new 
TimestampConverter(3);
-    private static final BASE64Decoder decoder = new BASE64Decoder();
+    private static final Base64.Decoder decoder = Base64.getDecoder();
 
     public static Object deserialize(
             String value,
@@ -61,7 +60,7 @@ public class StringSerializer {
                 if (isRGData) {
                     byte[] bytes = null;
                     try {
-                        bytes = decoder.decodeBuffer(value);
+                        bytes = decoder.decode(value);
                     } catch (Exception e) {
                         //
                     }