fix

apache · Mar 15, 2024 · e0218fb · e0218fb
1 parent 78cb38b
commit e0218fb
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...flink-common/src/test/java/org/apache/paimon/flink/source/TestChangelogDataReadWrite.java b/...flink-common/src/test/java/org/apache/paimon/flink/source/TestChangelogDataReadWrite.java
@@ -131,7 +131,7 @@ private TableRead createRead(
                         KeyValueFileReaderFactory.builder(
                                 LocalFileIO.create(),
                                 schemaManager,
-                                0,
+                                schemaManager.schema(0),
                                 KEY_TYPE,
                                 VALUE_TYPE,
                                 ignore -> avro,
@@ -175,11 +175,12 @@ public RecordWriter<KeyValue> createMergeTreeWriter(BinaryRow partition, int buc
 
         Map<String, FileStorePathFactory> pathFactoryMap = new HashMap<>();
         pathFactoryMap.put("avro", pathFactory);
+        SchemaManager schemaManager = new SchemaManager(LocalFileIO.create(), tablePath);
         RecordWriter<KeyValue> writer =
                 new KeyValueFileStoreWrite(
                                 LocalFileIO.create(),
-                                new SchemaManager(LocalFileIO.create(), tablePath),
-                                0,
+                                schemaManager,
+                                schemaManager.schema(0),
                                 commitUser,
                                 KEY_TYPE,
                                 VALUE_TYPE,