新版本flink1.17-1.19写入ES,官方例子报错 java.lang.IllegalStateException: The elasticsearch emitter must be serializable. 有大佬知道什么情况吗? 以下为热心网友提供的参考意见 试试不用lamda表达式,直接写成匿名类,类里面加上private static fi…
请问下大家有用过flink on k8s吗?我在kubernetes application模式下运行,运行一段时间后就会出现这个报错,然后jobmanager就重启了Exception occurred while acquiring lock ‘ConfigMapLock’:….Operation cannot be …