From 51c469aa6ffe6157749c1aa2394ac27e8a8b782d Mon Sep 17 00:00:00 2001 From: mcy Date: Tue, 19 Mar 2019 17:54:11 +0800 Subject: [PATCH] =?UTF-8?q?es=20etl=20=E4=B8=BB=E9=94=AE=E7=B1=BB=E5=9E=8B?= =?UTF-8?q?bug=20fix=20#1559?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../otter/canal/client/adapter/es/service/ESEtlService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/service/ESEtlService.java b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/service/ESEtlService.java index bf32cd14..646bcc47 100644 --- a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/service/ESEtlService.java +++ b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/service/ESEtlService.java @@ -247,7 +247,7 @@ public class ESEtlService { Object idVal = null; if (mapping.get_id() != null) { - idVal = rs.getObject(mapping.get_id()); + idVal = esFieldData.get(mapping.get_id()); } if (idVal != null) { @@ -271,7 +271,7 @@ public class ESEtlService { bulkRequestBuilder.add(indexRequestBuilder); } } else { - idVal = rs.getObject(mapping.getPk()); + idVal = esFieldData.get(mapping.getPk()); SearchResponse response = transportClient.prepareSearch(mapping.get_index()) .setTypes(mapping.get_type()) .setQuery(QueryBuilders.termQuery(mapping.getPk(), idVal))