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

请教个问题,用flink读本地文件可以得到输出结果,但是提交到flink单机模式服务器上执行jar包

请教个问题,用flink读本地文件可以得到输出结果,但是提交到flink单机模式服务器上执行jar包就看不到输出结果,任务2秒就结束了,也没有报错日志,有大神知道是什么原因吗?本地的执行结果image.png image.png

展开
收起
雪哥哥 2022-11-13 20:35:12 1708 0
3 条回答
写回答
取消 提交回答
  • 十分耕耘,一定会有一分收获!

    楼主首先需要添加一个错误信息打印的,然后排查一下看看是不是加载冲突引起的,再或者设置一下优先使用父类加载。

    2022-11-26 08:11:14
    赞同 展开评论 打赏
  • GitHub https://github.com/co63oc/cloud

    jar文件中增加错误信息打印

    2022-11-24 15:29:13
    赞同 展开评论 打赏
  • 天下风云出我辈,一入江湖岁月催,皇图霸业谈笑中,不胜人生一场醉。

    出现这种状况可能有以下两种: 1.打包上传后,加载类使用冲突,原因时集群lib目录下本身有这个Jar包,打包上传也带着这个Jar包,在加载时会出现类冲突 2.设置双亲委派机制(原理查看其它文章),在flink-conf.yaml中添加classloader.resolve-order: parent-first 优先使用父类加载器

    2022-11-23 11:01:06
    赞同 展开评论 打赏

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

相关产品

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

    更多
    如何运维千台以上游戏云服务器 立即下载
    网站/服务器取证 实践与挑战 立即下载
    ECS计算与存储分离架构实践 立即下载