具体报错sqlalchemy.exc.ProgrammingError: (pymysql.err.ProgrammingError) (1064, 'You have an error in your SQL syntax; check the manual that corresponds to your TiDB version for the right syntax to use line 1 column 12 near “请求模型” ')
[SQL: 请求模型]
两个库的字符集分别是什么
1 个赞
代码里面找一下 报错的 sql 语句,然后在 tidb 里面运行一下就知道哪里不兼容 mysql 了
2 个赞
去dashboard的日志搜索,搜索关键字“command dispatched failed”关键字,可以找到报错的SQL
2 个赞
语法支持的问题
我这儿用的sqldatabasechain去交互的 没有和具体的SQL语句有关联
你在tidb这里问其他中间件没有问题。
好歹提供一下flink-cdc-connectors版本信息。
至少看上去,现在已经不是这么写的了。
用的tidb 7.3, flink 1.17, flink-sql-connector-tidb-cdc 2.2.1, cdc用比2.2.1之后的版本就会出现cpu一直都是高占用的情况
1 个赞
long tableId = session.getCatalog().getTable(database, tableName).getId();
是获取tableid的时候报空指针了。
现在不确定是那个位置有空指针了。
报错的堆栈里面有其他的异常吗?
现在看下来tisession里面会判断这个session是否已经被关闭。
https://github.com/tikv/client-java/blob/v3.2.0/src/main/java/org/tikv/common/TiSession.java#L683
会不会是session过期的问题?
还有就是你的这个表会不会是个视图。
// https://github.com/pingcap/tispark/issues/961 // TODO: support reading from view table in the future.
看到注释说这里不支持视图。