From d859b80ccd44a177ed4fb99d321627ee253ee558 Mon Sep 17 00:00:00 2001
From: wudi <676366545@qq.com>
Date: Thu, 26 Sep 2024 18:47:29 +0800
Subject: [PATCH] update

---
 .../apache/doris/flink/table/DorisDynamicTableSource.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
index aaf5e9436..03d77bc36 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/table/DorisDynamicTableSource.java
+++ b/flink-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;
     }