(flink-connector-hive) 07/22: [FLINK-34204][core] Dispatch legacy serializer related methods in ExecutionConfig to SerializerConfig

[snuyanzin]

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

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

commit 756b1d9b4375844a995547632fd334672d99d154
Author: Weijie Guo <res...@163.com>
AuthorDate: Fri Jan 19 17:25:54 2024 +0800

    [FLINK-34204][core] Dispatch legacy serializer related methods in 
ExecutionConfig to SerializerConfig
---
 .../flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java
 
b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java
index c886692f..93ddb42b 100644
--- 
a/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java
+++ 
b/flink-connector-hive/src/test/java/org/apache/flink/connectors/hive/HiveSourceDynamicFileEnumeratorTest.java
@@ -18,7 +18,7 @@
 
 package org.apache.flink.connectors.hive;
 
-import org.apache.flink.api.common.ExecutionConfig;
+import org.apache.flink.api.common.serialization.SerializerConfigImpl;
 import org.apache.flink.api.common.typeinfo.TypeInformation;
 import org.apache.flink.api.java.tuple.Tuple3;
 import org.apache.flink.core.memory.DataOutputViewStreamWrapper;
@@ -219,7 +219,7 @@ class HiveSourceDynamicFileEnumeratorTest {
     private byte[] serialize(TypeInformation<RowData> typeInfo, RowData row) {
         ByteArrayOutputStream baos = new ByteArrayOutputStream();
         try {
-            typeInfo.createSerializer(new ExecutionConfig())
+            typeInfo.createSerializer(new SerializerConfigImpl())
                     .serialize(row, new DataOutputViewStreamWrapper(baos));
         } catch (IOException e) {
             // throw as RuntimeException so the function can use in lambda