wudi
wudi
> is there any incompatible change should be mentioned? eg. strip_outer_array Replaced strip_outer_array with read_json_line write in 1.1.0. you can refer to here https://github.com/apache/doris-flink-connector/issues/42
Thank you for your pr, is it also possible to add `@JsonIgnoreProperties(ignoreUnknown = true)` directly to the entity class of `QueryPlan` ?
> However, the response of queryPlan has been judged in `RestService.getQueryPlan`, and an `exception` is also thrown when an error occurs, so is there no need to record the exception...
> Customize the sink class, extends richsinkfunction and implement checkpointedfunction. In invoke dynamically sink through the properties in the custom entity object. The properties of the custom entity object are...
> Yes, encapsulate such a data structure, dynamically load by spelling the URL on the sink side, and add a keyby operator before sink At present, flink-doris-connector initiates the stream...
> Many users put all the canal logs of all tables in the business library into one topic, which needs to be distributed before they can use doris-flink-connector. His idea...
doris light schema change only supports add and drop columns. Other ddl operations will modify historical data, so it is relatively slow. You can refer to https://mp.weixin.qq.com/s/UqQnTJkGZhmMYxnUO9rdaQ
Yes, your current approach is fine. In the future, we will support streamload to support the semantics of multiple tables, so that a single sink can support the synchronization of...
Can you try the latest version 1.6.0?
It has been fixed and can be upgraded to 1.4.0 or 1.5.0. You can try it with the latest version.