fix import

apache · Oct 21, 2022 · 34bf52d · 34bf52d
1 parent de28764
commit 34bf52d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...rk-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/SerDeUtils.scala b/...rk-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/SerDeUtils.scala
@@ -17,6 +17,7 @@
 
 package org.apache.spark.sql.hudi
 
+import org.apache.hudi.common.util.BinaryUtil
 import org.apache.spark.SparkConf
 import org.apache.spark.serializer.{KryoSerializer, SerializerInstance}
 
@@ -34,7 +35,7 @@ object SerDeUtils {
 
   def toBytes(o: Any): Array[Byte] = {
     val buf = SERIALIZER_THREAD_LOCAL.get.serialize(o)
-    toBytes(buf)
+    BinaryUtil.toBytes(buf)
   }
 
   def toObject(bytes: Array[Byte]): Any = {