chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

查询数据过长变成byte数组转化为json解决 (#2090)

Browse Source 
Caused by: com.alibaba.fastjson.JSONException: syntax error, pos 2, json : [B@406b7f2 #2089
This commit is contained in:
wangwengeek
2019-08-23 17:38:22 +08:00
committed by agapple
parent 3a74f6124a
commit 983ff5fc73
1 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
client-adapter/elasticsearch/src/main/java/com/alibaba/otter/canal/client/adapter/es/support/ESSyncUtil.java
View File

@@ -44,8 +44,11 @@ public class ESSyncUtil {
String[] values = val.toString().split(separator); String[] values = val.toString().split(separator);
return Arrays.asList(values); return Arrays.asList(values);
} else if (fieldInfo.startsWith("object")) { } else if (fieldInfo.startsWith("object")) {
if (val instanceof String){
return JSON.parse(val.toString()); return JSON.parse(val.toString());
} }
return JSON.parse(new String((byte[])val));
}
return null; return null;
} }