es etl 主键类型bug fix #1559

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