flinkcdc 采集oceanbase sql执行报错

OceanBase 技术问题
,
#1

【 使用环境 】测试环境
【 OB or 其他组件 】flink1.153 oceanbase4.2.1.3,oblogproxy1.1.2
【 使用版本 】
【问题描述】清晰明确描述问题
【复现路径】问题出现前后相关操作
【附件及日志】E20240118 10:05:43.195482 13355 mysql_protocol.cpp:126] Auth user failed of server: 10.10.101.64:2881, user: root
E20240118 10:05:43.198498 13355 mysql_protocol.cpp:126] Auth user failed of server: 10.10.101.64:2881, user: root
E20240118 10:10:32.770547 13355 mysql_protocol.cpp:126] Auth user failed of server: 10.10.101.64:2881, user: root

#3

sql
image

#4

image
image1552×109 21.6 KB

#5

账号密码确定是可以连上的吗

#6
  1. ob 4.2.1.x 需要使用 oblogproxy 2.0.x 版本，https://github.com/oceanbase/oblogproxy/releases/tag/v2.0.0
  2. 4.x 的 libobcdc 不支持读取 sys 租户下的增量数据。

另外，oblogproxy 2.0 开始新增支持 mysql binlog 模式，可以直接使用 flink mysql cdc 来对接，推荐 社区用户使用 https://www.oceanbase.com/docs/community-oblogproxy-doc-1000000000438546

#7

1.image
老师我确认一下这个位置的用户名和密码是否就是下图配置的用户和密码
image
2.4.x不支持读取sys租户的增量数据，那是否支持存量数据的采集，

#8

image
我是用的这个位置的用户和密码，不晓得是不是对的

#9

操作步骤如下

2783af0c093ee1abbb326261349be79
2783af0c093ee1abbb326261349be79924×1030 27.4 KB

#10

报错

35a1446cd4bfaa54bfb372be8bbd3b7
35a1446cd4bfaa54bfb372be8bbd3b71741×316 49.9 KB

#11

上述问题已经处理了
分界线======================================================================
新的问题出现了

image
image1756×741 111 KB

#12

flink版本 1.15.3 oceanbase 4.2.1.3 oblogproxy-2.0.0, flink-sql-connector-oceanbase-cdc-2.2.0

#13

flink报错

image
image1614×747 149 KB

#14

对于 4.x 的 ob 来说， oblogproxy 执行 config_sys 时要配置的是 sys 租户的账号和密码，flink sql 里使用的应该是非 sys 租户的账号和密码。
最新的日志里显示的 查询 *_stat 表失败并不会影响增量日志的解析，可以忽略。不过我注意到您似乎在用比较旧的的 flink cdc，建议先升级到刚刚发布的最新版 https://github.com/ververica/flink-cdc-connectors/releases/tag/release-3.0.1

#15

最新版的flinkcdc 我的flink版本是否需要升级？

#16

增量数据是否只能是非sys租户的用户才能采集

#18

flink 版本不用改。4.x 是只能订阅非 sys 租户的增量数据，所以对应的要使用非 sys 租户的用户。