flink写入es,只能写入部分数据,之后就会停住

classic Classic list List threaded Threaded
1 message Options
ldq
Reply | Threaded
Open this post in threaded view
|

flink写入es,只能写入部分数据,之后就会停住

ldq
应用flinksql从kafka 写入es时,print显示kafka有22条数据,但添加flink sink后 print变为6条数据,且es也成功写入6条,请问什么原因 (flink 1.13.0 es 6.x )