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 setDeserializer(DorisDeserializationSchema d } public DorisSource build() { + if(readOptions == null){ + readOptions = DorisReadOptions.builder().build(); + } return new DorisSource<>(options, readOptions, boundedness, deserializer); } }