This is an automated email from the ASF dual-hosted git repository. diwu pushed a commit to branch connectorlink in repository https://gitbox.apache.org/repos/asf/doris-website.git
commit d590c90efc83e1e8bdb886e99a03cb493c8f730c Author: wudi <676366...@qq.com> AuthorDate: Wed Sep 25 14:14:15 2024 +0800 [doc](connecotr)update connector link --- common_docs_zh/ecosystem/flink-doris-connector.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/common_docs_zh/ecosystem/flink-doris-connector.md b/common_docs_zh/ecosystem/flink-doris-connector.md index ba7314e709e..03f667a53c3 100644 --- a/common_docs_zh/ecosystem/flink-doris-connector.md +++ b/common_docs_zh/ecosystem/flink-doris-connector.md @@ -279,7 +279,7 @@ builder.setDorisReadOptions(DorisReadOptions.builder().build()) env.fromSource(mySqlSource, WatermarkStrategy.noWatermarks(), "MySQL Source") .sinkTo(builder.build()); ``` -完整代码参考: [CDCSchemaChangeExample](https://github.com/apache/doris-flink-connector/blob/master/flink-doris-connector/src/test/java/org/apache/doris/flink/CDCSchemaChangeExample.java) +完整代码参考: [CDCSchemaChangeExample](https://github.com/apache/doris-flink-connector/blob/master/flink-doris-connector/src/test/java/org/apache/doris/flink/example/CDCSchemaChangeExample.java) ### Lookup Join @@ -865,4 +865,4 @@ Flink 在数据导入时,如果有脏数据,比如字段格式、长度等 16. **如果使用整库同步 MySQL 数据到 Doris,出现 timestamp 类型与源数据相差多个小时** -整库同步默认 timezone="UTC+8",如果你同步的数据不是该时区,可以尝试如下设置相对应的时区,例如:`--mysql-conf debezium.date.format.timestamp.zone="UTC+3"来解决。` \ No newline at end of file +整库同步默认 timezone="UTC+8",如果你同步的数据不是该时区,可以尝试如下设置相对应的时区,例如:`--mysql-conf debezium.date.format.timestamp.zone="UTC+3"来解决。` --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org