写入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回答
-
报错的那个对象以及代码中使用到的自己的对象都需要序列化才行
162019-07-01
相似问题