赞
踩
Exception in thread "main" 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:142)
at org.apache.flink.streaming.connectors.elasticsearch.ElasticsearchSinkBase.<init>(ElasticsearchSinkBase.java:215)
at org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink.<init>(Elasticsear
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。