开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC 提交jar包到flink的ui界面报错如下,请教下大家?

Flink CDC idea能正常消费kafka的数据,但是提交jar包到flink的ui界面报错如下,请教下大家,Caused by: org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: Failed to execute job 'Kafka Data Test'.
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:372)
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105)
at org.apache.flink.client.deployment.application.DetachedApplicationRunner.tryExecuteJobs(DetachedApplicationRunner.java:84)
我刚试了下重新打包提交jar包没解决,昨天jar包还是能正常提交在flink的ui界面运行。

展开
收起
真的很搞笑 2023-11-06 19:48:59 54 0
1 条回答
写回答
取消 提交回答
  • 有可能本地能运行、集群跑不了可能是jar包和集群环境冲突导致的,此回答整理自钉群“Flink CDC 社区”

    2023-11-08 07:41:06
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载