update fury to 0.4.0

Signed-off-by: chenxu <[email protected]>
lakesoul-io · Dec 7, 2023 · 90b7732 · 90b7732
1 parent aac6e24
commit 90b7732
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 4 deletions.
diff --git a/lakesoul-flink/pom.xml b/lakesoul-flink/pom.xml
@@ -250,7 +250,7 @@ SPDX-License-Identifier: Apache-2.0
         <dependency>
             <groupId>org.furyio</groupId>
             <artifactId>fury-core</artifactId>
-            <version>0.1.0</version>
+            <version>0.4.0</version>
         </dependency>
 
         <dependency>

diff --git a/...oul-flink/src/main/java/org/apache/flink/lakesoul/types/BinarySourceRecordSerializer.java b/...oul-flink/src/main/java/org/apache/flink/lakesoul/types/BinarySourceRecordSerializer.java
@@ -9,8 +9,8 @@
 import com.esotericsoftware.kryo.io.Input;
 import com.esotericsoftware.kryo.io.Output;
 import io.fury.Fury;
-import io.fury.Language;
 import io.fury.ThreadLocalFury;
+import io.fury.config.Language;
 import org.apache.flink.core.memory.MemorySegment;
 import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.data.binary.BinaryFormat;
@@ -78,10 +78,13 @@ public BinarySourceRecordSerializer() {
     }
 
     @Override public void write(Kryo kryo, Output output, BinarySourceRecord object) {
-        fury.getCurrentFury().serializeJavaObject(output, object);
+        fury.execute(f -> {
+            f.serializeJavaObject(output, object);
+            return 0;
+        });
     }
 
     @Override public BinarySourceRecord read(Kryo kryo, Input input, Class<BinarySourceRecord> type) {
-        return fury.getCurrentFury().deserializeJavaObject(input, BinarySourceRecord.class);
+        return fury.execute(f -> f.deserializeJavaObject(input, BinarySourceRecord.class));
     }
 }