We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fb0b1c1 commit 4927ef0Copy full SHA for 4927ef0
pkg/common/event/util.go
@@ -494,6 +494,11 @@ func BatchDML(dml *DMLEvent) *BatchDMLEvent {
494
// Only the table with pk and no uk can always be splitted in all sinks.
495
// Notice: please ensure the logic of IsSplitable is totally the same with isSplitable in utils
496
func IsSplitable(tableInfo *common.TableInfo) bool {
497
+ // some ddl jobs do not have table info, such as drop database, we just ignore checking these jobs
498
+ if tableInfo == nil {
499
+ return true
500
+ }
501
+
502
if tableInfo.GetPkColInfo() == nil {
503
return false
504
}
0 commit comments