update

JNSimba · Sep 26, 2024 · d859b80 · d859b80
1 parent afe8abf
commit d859b80
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...k-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java b/...k-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
@@ -169,7 +169,11 @@ public DynamicTableSource copy() {
         // filterQuery/readFields of readOption may be overwritten in union all sql
         DorisDynamicTableSource newSource =
                 new DorisDynamicTableSource(
-                        options, readOptions.copy(), lookupOptions, physicalSchema, physicalRowDataType);
+                        options,
+                        readOptions.copy(),
+                        lookupOptions,
+                        physicalSchema,
+                        physicalRowDataType);
         newSource.resolvedFilterQuery = new ArrayList<>(this.resolvedFilterQuery);
         return newSource;
     }