diff --git a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java index bf4c1921..598204f0 100644 --- a/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java +++ b/server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java @@ -417,9 +417,9 @@ public class MQMessageUtils { pkNames = flatMessage.getPkNames(); } - int hashCode = table.hashCode(); int idx = 0; for (Map row : flatMessage.getData()) { + int hashCode = table.hashCode(); if (!hashMode.tableHash) { for (String pkName : pkNames) { String value = row.get(pkName);