From 983ff5fc73fa3be65a08af6d0b1024e52a153803 Mon Sep 17 00:00:00 2001
From: wangwengeek <740983056@qq.com>
Date: Fri, 23 Aug 2019 17:38:22 +0800
Subject: [PATCH] =?UTF-8?q?=E6=9F=A5=E8=AF=A2=E6=95=B0=E6=8D=AE=E8=BF=87?=
 =?UTF-8?q?=E9=95=BF=E5=8F=98=E6=88=90byte=E6=95=B0=E7=BB=84=E8=BD=AC?=
 =?UTF-8?q?=E5=8C=96=E4=B8=BAjson=E8=A7=A3=E5=86=B3=20(#2090)?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Caused by: com.alibaba.fastjson.JSONException: syntax error, pos 2, json : [B@406b7f2 #2089
---
 .../otter/canal/client/adapter/es/support/ESSyncUtil.java    | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java
index 36d0c672..ca10f6c9 100644
--- a/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java
+++ b/client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java
@@ -44,7 +44,10 @@ public class ESSyncUtil {
             String[] values = val.toString().split(separator);
             return Arrays.asList(values);
         } else if (fieldInfo.startsWith("object")) {
-            return JSON.parse(val.toString());
+            if (val instanceof String){
+                return JSON.parse(val.toString());
+            }
+            return JSON.parse(new String((byte[])val));
         }
         return null;
     }