wj596/go-mysql-transfer

oldRow 不是update状态清除数据

xuweiguo opened this issue · 0 comments

service/luaengine/redis_actuator.go:189

	if action == canal.UpdateAction {
		oldRow := L.NewTable()
		paddingTable(L, oldRow, previous)
		L.SetGlobal(_globalOLDROW, oldRow)
	}

我认为如果是非更新需要,清除这个_globalOLDROW 值 避免 非update中取到之前的oldRow