Browse Source

Merge pull request #34 from alibaba/master

merge
rewerma 6 years ago
parent
commit
79a3961da1

+ 1 - 1
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<String, String> row : flatMessage.getData()) {
+                        int hashCode = table.hashCode();
                         if (!hashMode.tableHash) {
                             for (String pkName : pkNames) {
                                 String value = row.get(pkName);