Open tubage0425 opened 7 months ago
Since Flink Connector 1.5.0, the DorisSourceBuilder has been removed. You can find more details in PR: https://github.com/apache/doris-flink-connector/pull/189. It may be beneficial to update the documentation on the Doris website accordingly.
Search before asking
Version
version 2.1
What's Wrong?
As for the following Flink Doris Connector sample code, you incorrectly used
DorisSourceBuilder
to obtain DorisSource. It should be DorisSource.<List<?>>builder().bulid()sample code in the doc(EcoSystem/Flink Doris Connector): DorisSource<List<?>> dorisSource = DorisSourceBuilder.<List<?>>builder() .setDorisOptions(builder.build()) .setDorisReadOptions(DorisReadOptions.builder().build()) .setDeserializer(new SimpleListDeserializationSchema()) .build();
What You Expected?
Correct code to get DorisSource should be as below:
DorisSource<List<?>> dorisSource = DorisSource.<List<?>>bulider .setDorisOptions(builder.build()) .setDorisReadOptions(DorisReadOptions.builder().build()) .setDeserializer(new SimpleListDeserializationSchema()) .build();
How to Reproduce?
No response
Anything Else?
NO
Are you willing to submit PR?
Code of Conduct