[Improve] Empty readOptions in the Build() method of setDorisReadOpti…

…ons (#175)
apache · Aug 10, 2023 · 31f76da · 31f76da
1 parent d72d7a9
commit 31f76da
Showing 1 changed file with 3 additions and 0 deletions.
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
@@ -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);
     }
 }