新版本flink1.17-1.19写入ES,官方例子报错 java.lang.IllegalStateException: The elasticsearch emitter must be serializable. 有大佬知道什么情况吗？![新版本flink1.17-1.19写入ES,官方例子报错有知道什么情况吗？-[阿里云_云淘科技]](http://www.cnzhanzhang.com/wp-content/uploads/2023/12/20231223075038-6586914e17a00.png)
![新版本flink1.17-1.19写入ES,官方例子报错有知道什么情况吗？-[阿里云_云淘科技]](https://www.cnzhanzhang.com/wp-content/themes/justnews/themer/assets/images/lazy.png)
以下为热心网友提供的参考意见
试试不用lamda表达式，直接写成匿名类，类里面加上private static final long serial VersionUID语句 ，此回答整理自钉群“【③群】Apache Flink China社区”
本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/11589.html