Skip to content

Commit

Permalink
[typo](doc)Add flink to read the doris table and use doris.filter.que…
Browse files Browse the repository at this point in the history
…ry to configure the display (apache#24736)
  • Loading branch information
caoliang-web authored and vinlee19 committed Oct 7, 2023
1 parent 4e1377e commit 0a8383c
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 0 deletions.
4 changes: 4 additions & 0 deletions docs/en/docs/ecosystem/flink-doris-connector.md
Original file line number Diff line number Diff line change
Expand Up @@ -688,3 +688,7 @@ This is due to concurrency bugs in the Thrift. It is recommended that you use th
13. **DorisRuntimeException: Fail to abort transaction 26153 with url http://192.168.0.1:8040/api/table_name/_stream_load_2pc**
You can search for the log `abort transaction response` in TaskManager and determine whether it is a client issue or a server issue based on the HTTP return code.
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.
4 changes: 4 additions & 0 deletions docs/zh-CN/docs/ecosystem/flink-doris-connector.md
Original file line number Diff line number Diff line change
Expand Up @@ -690,3 +690,7 @@ Flink在数据导入时,如果有脏数据,比如字段格式、长度等问
13. **DorisRuntimeException: Fail to abort transaction 26153 with url http://192.168.0.1:8040/api/table_name/_stream_load_2pc**
你可以在 TaskManager 中搜索日志 `abort transaction response`,根据 http 返回码确定是 client 的问题还是 server 的问题。
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 解析器会将两个连续的单引号解释为一个单引号字符,而不是字符串的结束,并将拼接后的字符串作为属性的值。

0 comments on commit 0a8383c

Please sign in to comment.