flink 1.9 消费kafka报错
大家好, 升级到1.9后有几个问题: 1.现在的线上版本是1.7.2,以前的代码的kafka consumer是使用的FlinkKafkaConsumer011 val consumer = new FlinkKafkaConsumer011[String](kafkaTopic, new Simp...
flink消费kafka报错 Couldn't retrieve the JobExecutionResult from the JobManager
Starting execution of programSubmitting job with JobID: aca099531abda417700799ace53e0fbd. Waiting for job completion.The program finished with the fol...
更新时间 2022-12-16 18:03:44
本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。
社区圈子