com.alibaba.fastjson.JSONException: syntax error, pos 1

1、错误情况：(PollableSourceRunner-KafkaSource-r1) [ERROR - org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:330)] KafkaSource EXCEPTION, {}com.alibaba.fastjson.JSONException: syntax err

weixin_42444887

12177人浏览 · 2021-11-10 04:47:44

weixin_42444887 · 2021-11-10 04:47:44 发布

1、错误情况：

(PollableSourceRunner-KafkaSource-r1) [ERROR - org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:330)] KafkaSource EXCEPTION, {}
com.alibaba.fastjson.JSONException: syntax error, pos 1, line 1, column 2sa
   at com.alibaba.fastjson.parser.DefaultJSONParser.parse(DefaultJSONParser.java:1480)
   at com.alibaba.fastjson.parser.DefaultJSONParser.parse(DefaultJSONParser.java:1366)
   at com.alibaba.fastjson.JSON.parse(JSON.java:170)
   at com.alibaba.fastjson.JSON.parse(JSON.java:180)
   at com.alibaba.fastjson.JSON.parse(JSON.java:149)
   at com.alibaba.fastjson.JSON.parseObject(JSON.java:241)
   at com.albert.gmall.flume.interceptor.TimeStampInterceptor.intercept(TimeStampInterceptor.java:23)
   at com.albert.gmall.flume.interceptor.TimeStampInterceptor.intercept(TimeStampInterceptor.java:35)
   at org.apache.flume.interceptor.InterceptorChain.intercept(InterceptorChain.java:62)
   at org.apache.flume.channel.ChannelProcessor.processEventBatch(ChannelProcessor.java:148)
   at org.apache.flume.source.kafka.KafkaSource.doProcess(KafkaSource.java:311)
   at org.apache.flume.source.AbstractPollableSource.process(AbstractPollableSource.java:60)
   at org.apache.flume.source.PollableSourceRunner$PollingRunner.run(PollableSourceRunner.java:133)
   at java.lang.Thread.run(Thread.java:748)

2、错误原因

log 没有进行判断是否有值

3、解决办法

给json对象赋值前先判断有无数据，如果有直接这样赋值；否则返回null