新版本flink1.17-1.19写入ES,官方例子报错 java.lang.IllegalStateException: The elasticsearch emitter must be serializable. 有大佬知道什么情况吗？
以下为热心网友提供的参考意见
试试不用lamda表达式，直接写成匿名类，类里面加上private static final long serial VersionUID语句 ，此回答整理自钉群“【③群】Apache Flink China社区”
0°
新版本flink1.17-1.19写入ES,官方例子报错有知道什么情况吗？[阿里云polardb]
「点点赞赏，手留余香」
还没有人赞赏，快来当第一个赞赏的人吧！