chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

删除操作计算hash值的情况没有考虑，导致删除时的分区和插入时的分区不一致 (#1848)

Browse Source
This commit is contained in:
Marsss___
2019-05-27 23:54:25 +08:00
committed by agapple
parent d0a83aad27
commit 37fc248ebf
1 changed files with 18 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
server/src/main/java/com/alibaba/otter/canal/common/MQMessageUtils.java
View File

@@ -230,12 +230,27 @@ public class MQMessageUtils {
} }
} }
} else { } else {
try {
CanalEntry.EventType eventType = RowChange.parseFrom(entry.getStoreValue()).getEventType();
if(eventType == CanalEntry.EventType.DELETE){
for (CanalEntry.Column column : rowData.getBeforeColumnsList()) {
if (checkPkNamesHasContain(hashMode.pkNames, column.getName())) {
hashCode = hashCode ^ column.getValue().hashCode();
}
}
}
else {
for (CanalEntry.Column column : rowData.getAfterColumnsList()) { for (CanalEntry.Column column : rowData.getAfterColumnsList()) {
if (checkPkNamesHasContain(hashMode.pkNames, column.getName())) { if (checkPkNamesHasContain(hashMode.pkNames, column.getName())) {
hashCode = hashCode ^ column.getValue().hashCode(); hashCode = hashCode ^ column.getValue().hashCode();
} }
} }
} }
}
catch (InvalidProtocolBufferException e) {
e.printStackTrace();
}
}
int pkHash = Math.abs(hashCode) % partitionsNum; int pkHash = Math.abs(hashCode) % partitionsNum;
pkHash = Math.abs(pkHash); pkHash = Math.abs(pkHash);