From 7e2ae8bd2c5906f0bc6c1c18e6dc749e0fdbd33c Mon Sep 17 00:00:00 2001
From: WangJiangZhou <1634846162@qq.com>
Date: Tue, 8 Aug 2023 19:47:57 +0800
Subject: [PATCH] [Bug] [Connector] Empty readOptions in the Build() method of
 setDorisReadOptions

---
 .../java/org/apache/doris/flink/source/DorisSourceBuilder.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java
index 8d96c08a0..94febb8c8 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/source/DorisSourceBuilder.java
@@ -63,6 +63,9 @@ public DorisSourceBuilder<OUT> setDeserializer(DorisDeserializationSchema<OUT> d
     }
 
     public DorisSource<OUT> build() {
+        if(readOptions == null){
+            readOptions = DorisReadOptions.builder().build();
+        }
         return new DorisSource<>(options, readOptions, boundedness, deserializer);
     }
 }