From 44beaf191655973e9c79e4fcb071bd44e9dfe61f Mon Sep 17 00:00:00 2001
From: i404 <linhaoisbr@gmail.com>
Date: Thu, 14 Feb 2019 18:26:01 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=BD=93=20canal.mq.flatMess?=
 =?UTF-8?q?age=20=3D=20true=20=E6=97=B6=EF=BC=8CMQMessageUtils::messagePar?=
 =?UTF-8?q?tition=20=E6=95=B0=E6=8D=AE=E5=88=86=E5=8C=BA=E9=94=99=E8=AF=AF?=
 =?UTF-8?q?=E7=9A=84=20bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/com/alibaba/otter/canal/common/MQMessageUtils.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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