Przeglądaj źródła

Merge pull request #1507 from i404/master

修复 FlatMessage  Hash 到不正确的分区的Bug。
agapple 6 lat temu
rodzic
commit
e07db7b178

+ 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);