写入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

已采纳

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

weixin_慕瓜4097003

非常感谢！

2019-07-01

共6条回复

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

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

969 学习 · 296 问题

查看课程

相似问题

序列化

回答 1

private transient ValueState

回答 1

如果Connection可序列化是不是用map也可以

回答 1

问题解决成功运行了

回答 1

dataset的数据要写入es7中

回答 1

打开慕课网App查看更多内容