From 476244b26d84e3752801683f1e1e954afbe55498 Mon Sep 17 00:00:00 2001 From: mcy Date: Thu, 14 Feb 2019 15:41:27 +0800 Subject: [PATCH] modify --- .../otter/canal/client/adapter/es/support/ESTemplate.java | 4 ---- 1 file changed, 4 deletions(-) diff --git a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESTemplate.java b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESTemplate.java index 3230a01e..5974883d 100644 --- a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESTemplate.java +++ b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESTemplate.java @@ -9,7 +9,6 @@ import java.util.concurrent.ConcurrentMap; import javax.sql.DataSource; -import com.alibaba.fastjson.JSONObject; import org.elasticsearch.action.bulk.BulkItemResponse; import org.elasticsearch.action.bulk.BulkRequestBuilder; import org.elasticsearch.action.bulk.BulkResponse; @@ -192,9 +191,6 @@ public class ESTemplate { private void commitBulk() { if (getBulk().numberOfActions() >= MAX_BATCH_SIZE) { commit(); - - JSONObject jsonObject = new JSONObject(); - jsonObject.toJavaObject(Object.class); } }