[Bug] [Connector] Empty readOptions in the Build() method of setDoris…

…ReadOptions
apache · Aug 8, 2023 · 7e2ae8b · 7e2ae8b
1 parent be1c5ce
commit 7e2ae8b
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);
     }
 }