From 27d711e5d29e3c807345e54cf9d926c04b32ebcb Mon Sep 17 00:00:00 2001 From: yukun Date: Tue, 16 Nov 2021 14:21:27 +0800 Subject: [PATCH] Insert task hash by primarykeys (#11819) Signed-off-by: fishpenguin --- internal/proxy/task.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/proxy/task.go b/internal/proxy/task.go index 8a9da15ccb..9bc7080d04 100644 --- a/internal/proxy/task.go +++ b/internal/proxy/task.go @@ -687,10 +687,9 @@ func (it *insertTask) checkFieldAutoIDAndHashPK() error { Data: it.BaseInsertTask.RowIDs, }, } - it.HashPK(it.BaseInsertTask.RowIDs) } else { - it.HashPK(it.BaseInsertTask.RowIDs) + it.HashPK(primaryData) } sliceIndex := make([]uint32, rowNums)