This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 287bd87a4f9 [typo](docs)add some faq for flink-connector-doris (#26309)
287bd87a4f9 is described below
commit 287bd87a4f9e6cd69f7083ce51863f1c44a9cb4a
Author: Petrichor <[email protected]>
AuthorDate: Sat Dec 9 02:19:49 2023 +0800
[typo](docs)add some faq for flink-connector-doris (#26309)
* add flink-connector-doris faq
* add faq
---
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 0b211748cfe..1f1cf8b29fb 100644
--- a/docs/en/docs/ecosystem/flink-doris-connector.md
+++ b/docs/en/docs/ecosystem/flink-doris-connector.md
@@ -757,3 +757,7 @@ You can search for the log `abort transaction response` in
TaskManager and deter
14. **org.apache.flink.table.api.SqlParserException when using
doris.filter.query: SQL parsing failed. "xx" encountered at row x, column xx**
This problem is mainly caused by the conditional varchar/string type, which
needs to be quoted. The correct way to write it is xxx = ''xxx''. In this way,
the Flink SQL parser will interpret two consecutive single quotes as one single
quote character instead of The end of the string, and the concatenated string
is used as the value of the attribute.
+
+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 [...]
diff --git a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
index 6222e4e8281..ef1e8c5cbe3 100644
--- a/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
+++ b/docs/zh-CN/docs/ecosystem/flink-doris-connector.md
@@ -759,3 +759,7 @@ Flink在数据导入时，如果有脏数据，比如字段格式、长度等问
14. **使用doris.filter.query出现org.apache.flink.table.api.SqlParserException: SQL
parse failed. Encountered "xx" at line x, column xx**
出现这个问题主要是条件varchar/string类型，需要加引号导致的，正确写法是 xxx = ''xxx'',这样Flink SQL
解析器会将两个连续的单引号解释为一个单引号字符,而不是字符串的结束，并将拼接后的字符串作为属性的值。
+
+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...`。
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
