flinkcdc采集ob

【 使用环境 】测试环境
【 OB or 其他组件 】OB
【 使用版本 】5.7.25-OceanBase_CE-v4.3.5.3，flink-connector-oceanbase-cdc-3.5.0
【问题描述】Caused by: java.sql.SQLSyntaxErrorException: You have an error in your SQL syntax; check the manual that corresponds to your OceanBase version for the right syntax to use near ‘MASTER STATUS’ at line 1
[172.17.0.7:2882] [2026-03-10 06:22:08.959264] [YB42AC110007-00064C90BC0F3063-0-0]
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:118)
at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:95)
at com.mysql.cj.jdbc.exceptions.SQLExceptionsMapping.translateException(SQLExceptionsMapping.java:122)
at com.mysql.cj.jdbc.StatementImpl.executeQuery(StatementImpl.java:1247)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:641)
at io.debezium.jdbc.JdbcConnection.queryAndMap(JdbcConnection.java:510)
at org.apache.flink.cdc.connectors.mysql.debezium.DebeziumUtils.currentBinlogOffset(DebeziumUtils.java:123)
… 7 more
【复现路径】问题出现前后相关操作
【附件及日志】推荐使用OceanBase敏捷诊断工具obdiag收集诊断信息,详情参见链接（右键跳转查看）：

【SOP系列 22 】——故障诊断第一步(自助诊断和诊断信息收集)

【备注】基于 LLM 和开源文档 RAG 的论坛小助手已开放测试，在发帖时输入 [@论坛小助手] 即可召唤小助手，欢迎试用！

推荐使用 obdiag 工具进行日志采集，这将有助于我们更好地了解您的问题并找到根本原因。

日志采集场景: SQL执行出错
日志采集命令: obdiag gather scene run --scene=observer.sql_err --env “{db_connect=’-h127.0.0.1 -P2881 -utest@test -p****** -Dtest’, trace_id=‘Yxx’}”

上述命令将收集与 SQL 执行错误相关的日志信息，其中db_connect参数需替换为您实际使用的数据库连接字符串，而trace_id则需要根据您遇到问题时的跟踪 ID 进行替换。

为了更准确地诊断问题，请您提供以下信息：

1. 您尝试执行的具体 SQL 语句是什么？
2. 您的 Flink 连接器配置详情，特别是版本信息和任何可能影响 SQL 兼容性的设置。
3. 能否提供发生错误的时间点，以便我们能在日志中查找相关信息？
4. 您是否尝试过直接在 OceanBase 上执行同样的 SQL 语句？如果有，结果如何？
5. 是否可以提供一个最小化复现该问题的示例，包括创建表结构的 SQL 和插入数据的语句等？

请您按照上述提示操作，并提供相关信息，我们将尽快为您解决问题。谢谢！

附上敏捷诊断工具 obdiag 使用帮助链接

需要用flinkcdc做实时采集

@AntTech_UVFH2H flink-cdc 实时采集 ob 。需要部署配置 oceanbase binlog服务。

image2510×1264 500 KB

1、https://www.oceanbase.com/docs/oblogproxy-doc
2、https://nightlies.apache.org/flink/flink-cdc-docs-master/zh/docs/connectors/flink-sources/oceanbase-cdc/