This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 05f525e922baba869eb690881caf4c57ca92c4fa Author: Petrichor <[email protected]> AuthorDate: Thu Feb 29 23:19:59 2024 +0800 [improvement](docs)add faq for flink-connector-doris (#31426) --- docs/en/docs/ecosystem/flink-doris-connector.md | 4 ++++ docs/zh-CN/docs/ecosystem/flink-doris-connector.md | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/docs/en/docs/ecosystem/flink-doris-connector.md b/docs/en/docs/ecosystem/flink-doris-connector.md index b5cfbe2def3..256b15e94a6 100644 --- a/docs/en/docs/ecosystem/flink-doris-connector.md +++ b/docs/en/docs/ecosystem/flink-doris-connector.md @@ -784,3 +784,7 @@ This problem is mainly caused by the conditional varchar/string type, which need 15. **Failed to connect to backend: http://host:webserver_port, and BE is still alive** The issue may have occurred due to configuring the IP address of `be`, which is not reachable by the external Flink cluster.This is mainly because when connecting to `fe`, the address of `be` is resolved through fe. For instance, if you add a be address as '127.0.0.1', the be address obtained by the Flink cluster through fe will be '127.0.0.1:webserver_port', and Flink will connect to that address. When this issue arises, you can resolve it by adding the actual corresponding external IP [...] + +16. **When using Flink-connector to synchronize MySQL data to Doris, there is a time difference of several hours between the timestamp.** + +Flink Connector synchronizes the entire database from MySQL with a default timezone of UTC+8. If your data resides in a different timezone, you can adjust it using the following configuration, for example: `--mysql-conf debezium.date.format.timestamp.zone="UTC+3"`. diff --git a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md index cf3f22ef2f5..5c51da5f0a7 100644 --- a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md +++ b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md @@ -784,3 +784,7 @@ Flink在数据导入时，如果有脏数据，比如字段格式、长度等问 15. **如果出现Failed to connect to backend: http://host:webserver_port, 并且Be还是活着的** 可能是因为你配置的be的ip，外部的Flink集群无法访问。这主要是因为当连接fe时，会通过fe解析出be的地址。例如，当你添加的be 地址为`127.0.0.1`，那么Flink通过fe获取的be地址就为`127.0.0.1:webserver_port`， 此时Flink就会去访问这个地址。当出现这个问题时，可以通过在with属性中增加实际对应的be外部ip地`'benodes' = "be_ip:webserver_port, be_ip:webserver_port..."`，整库同步则可增加`--sink-conf benodes=be_ip:webserver,be_ip:webserver...`。 + +16. **如果使用整库同步 MySQL 数据到 Doris，出现 timestamp 类型与源数据相差多个小时** + +整库同步默认timezone="UTC+8"，如果你同步的数据不是该时区，可以尝试如下设置相对应的时区，例如：`--mysql-conf debezium.date.format.timestamp.zone="UTC+3"来解决。` --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
