Fix flink getUTF8Bytes and some tests

apache · Sep 12, 2023 · 75b9207 · 75b9207
1 parent dc916fc
commit 75b9207
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java b/...client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataParquetWriteSupport.java
@@ -21,6 +21,7 @@
 import org.apache.hudi.avro.HoodieBloomFilterWriteSupport;
 import org.apache.hudi.common.bloom.BloomFilter;
 import org.apache.hudi.common.util.Option;
+import org.apache.hudi.common.util.StringUtils;
 
 import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.types.logical.RowType;
@@ -70,7 +71,7 @@ public HoodieBloomFilterRowDataWriteSupport(BloomFilter bloomFilter) {
 
     @Override
     protected byte[] getUTF8Bytes(String key) {
-      return getUTF8Bytes(key);
+      return StringUtils.getUTF8Bytes(key);
     }
   }
 }