请稍等 ...

写入es报没有序列化

图片描述

图片描述图片描述、

加入sink一直报错：
java.lang.IllegalArgumentException: The implementation of the provided ElasticsearchSinkFunction is not serializable. The object probably contains or references non-serializable fields.

at org.apache.flink.util.Preconditions.checkArgument(Preconditions.java:139)

weixin_慕瓜4097003 2019-06-28 09:38:24

源自：11-14 统计分析数据写入ES并通过Kibana展示出来

623

收起

提交取消

1回答

Michael_PK 回答被采纳获得+3积分 2019-06-28 09:57:09

报错的那个对象以及代码中使用到的自己的对象都需要序列化才行

1 回复有任何疑惑可以回复我~

收起回答

提问者 weixin_慕瓜4097003 #1

FlinkTestDto implements Serializable 这样也不行。其他的都不是自己自定义的对象了

回复有任何疑惑可以回复我~ 2019-06-28 10:19:10

Michael_PK 回复提问者 weixin_慕瓜4097003 #2
```
你这个是按照视频里面写的吗？
```
回复有任何疑惑可以回复我~ 2019-06-28 10:20:05
提问者 weixin_慕瓜4097003 回复 Michael_PK #3
```
不是耶，我从mysql读数据出来的
```
回复有任何疑惑可以回复我~ 2019-06-28 10:21:17