fix comment

apache · Dec 9, 2024 · 29c54fc · 29c54fc
1 parent c5a039e
commit 29c54fc
Showing 1 changed file with 4 additions and 2 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
@@ -166,8 +166,10 @@ public List<DataFileMeta> writeFiles(
     }
 
     public RecordWriter<KeyValue> createMergeTreeWriter(BinaryRow partition, int bucket) {
-        CoreOptions options =
-                new CoreOptions(Collections.singletonMap(CoreOptions.FILE_FORMAT.key(), "avro"));
+        Map<String, String> optionMap = new HashMap<>();
+        optionMap.put(CoreOptions.FILE_FORMAT.key(), "avro");
+        optionMap.put(CoreOptions.STORAGE_THIN_MODE.key(), "false");
+        CoreOptions options = new CoreOptions(optionMap);
 
         Map<String, FileStorePathFactory> pathFactoryMap = new HashMap<>();
         pathFactoryMap.put("avro", pathFactory);