Dm新版本启动worker后报错

alwaystest18 · 2019 年9 月 11 日 06:09

启动worker后，log里出现大量如下错误
[2019/09/11 13:28:01.702 +08:00] [ERROR] [common.go:35] ["parse statement"] [sql="SAVEPOINT SAVEPOINT_1"] [error="line 1 column 9 near "SAVEPOINT SAVEPOINT_1" "]

此时worker仅做拉取binlog功能，且binlog拉取正常，在启动task后该报错消失，目前task运行正常

Lucien · 2019 年9 月 11 日 06:13

dm-worker 启动时候没有过滤掉 SAVEPOINT 的操作，拉去 rely.log 动作只是将上游 MySQL Binlog file 拉取到本地，不会涉及 Parse 这个动作，所以请确认这个日志是否是启动的操作？或者补充上下完整的 dm-worker 日志。

启动 task 任务在 syncer 状态会将 SAVEPOINT 跳过。

github.com

pingcap/dm/blob/54e18df01de6c83df30049621ec49a521ce7033e/syncer/filter.go#L35


      
          	"github.com/pingcap/dm/pkg/terror"
          )
          
          /*
          CREATE [TEMPORARY] TABLE [IF NOT EXISTS] tbl_name
              { LIKE old_tbl_name | (LIKE old_tbl_name) }
          */
          var (
          	builtInSkipDDLs = []string{
          		// transaction
          		"^SAVEPOINT",
          
          		// skip all flush sqls
          		"^FLUSH",
          
          		// table maintenance
          		"^OPTIMIZE\\s+TABLE",
          		"^ANALYZE\\s+TABLE",
          		"^REPAIR\\s+TABLE",
          
          		// temporary table

alwaystest18 · 2019 年9 月 11 日 06:40

是的，这个是worker刚启动之后的报错

Lucien · 2019 年9 月 11 日 07:35

请问 dm-worker 是初始化启动？还是重启操作？

alwaystest18 · 2019 年9 月 11 日 07:51

重启操作

Lucien · 2019 年9 月 11 日 08:08

重启的日志报错是预期的，这里面 dm-worker 进行 relay_log 实际也会进行 DDL check 工作，这里会涉及到 Parse 操作，如果解析不了，那么就会出现这个日志报错。这里和 sync 模块处理方式不太一样，sync 模块会对不处理的 DDL 语句进行 skip 操作，后面有考虑会调整的。

IANTHEREAL · 2019 年9 月 11 日 10:05

这个报错对运行是没有影响的，dm 会对不支持的 ddl 解析进行报错，但是会兼容处理。请问你使用的版本是 dm 1.0.1 吗？

system · 2022 年10 月 31 日 19:10

此话题已在最后回复的 1 分钟后被自动关闭。不再允许新回复。