写入es报没有序列化

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

weixin_慕瓜4097003

2019-06-28

图片描述

图片描述图片描述、

加入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)
写回答

1回答

Michael_PK

2019-06-28

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

1
6
weixin_慕瓜4097003
非常感谢!
2019-07-01
共6条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程