From 0cf18976d996787921e2eb5337df99a5436792bc Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9D=B3=E5=85=89=E5=AE=87?= Date: Fri, 28 Jun 2019 14:56:51 +0800 Subject: [PATCH] Update HbaseSyncService.java (#1936) Fix batch update or delete with only affects the first data issue --- .../client/adapter/hbase/service/HbaseSyncService.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseSyncService.java b/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseSyncService.java index 3a849c9e..e0dc1279 100644 --- a/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseSyncService.java +++ b/client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseSyncService.java @@ -200,8 +200,7 @@ public class HbaseSyncService { String rowKeyVale = getRowKeys(rowKeyColumns, r); rowKeyBytes = Bytes.toBytes(rowKeyVale); } else if (rowKeyColumn == null) { - Map rowKey = data.get(0); - rowKeyBytes = typeConvert(null, hbaseMapping, rowKey.values().iterator().next()); + rowKeyBytes = typeConvert(null, hbaseMapping, r.values().iterator().next()); } else { rowKeyBytes = getRowKeyBytes(hbaseMapping, rowKeyColumn, r); } @@ -285,8 +284,7 @@ public class HbaseSyncService { rowKeyBytes = Bytes.toBytes(rowKeyVale); } else if (rowKeyColumn == null) { // 如果不需要类型转换 - Map rowKey = data.get(0); - rowKeyBytes = typeConvert(null, hbaseMapping, rowKey.values().iterator().next()); + rowKeyBytes = typeConvert(null, hbaseMapping, r.values().iterator().next()); } else { rowKeyBytes = getRowKeyBytes(hbaseMapping, rowKeyColumn, r); }