瀏覽代碼

修复当 canal.mq.flatMessage = true 时,MQMessageUtils::messagePartition 数据分区错误的 bug

i404 6 年之前
父節點
當前提交
44beaf1916
共有 1 個文件被更改,包括 1 次插入1 次删除
  1. 1 1
      server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java

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