关于flunk的任务提交

来源:8-6 ZooKeeper部署

慕函数2082699

2020-03-15

我创建了java的flink job,普通功能,maven的插件配置如下:
图片描述
然后,我通过flink的web UI,提交任务,功能job能正常启动
图片描述
图片描述
但是,同一个jar包,同用cli的flink run来启动,不报错,但是一直卡在以下界面,就没有后续了
图片描述
在flink-root-client-hadoop000.log的日志中,也没有报错,就到了Submitting job 069d18ce2ff6d05ad9f18d188f1133a2 (detached: false).之后就卡住了,也不报错,也没有后续了
图片描述

不知道问题处在哪里?求救求指导

写回答

3回答

Michael_PK

2020-12-23

这个日志真心看不出来具体是什么错误引起的。

这么滴,你把运行的日志降低到debug,看看有啥能看到的详细的信息

0
0

qq_慕婉清7221160

2020-12-23

请问一下您解决了吗,我也遇到了这个问题,求帮助--。。--

0
0

Michael_PK

2020-03-15

你这是什么作业,数据源在哪里?是否有数据接入

0
6
Michael_PK
回复
慕函数2082699
你可以QQ找我下,Scala项目也可以Java的
2020-03-16
共6条回复

新一代大数据计算引擎 Flink从入门到实战

入行或转型大数据新姿势,多语言系统化讲解,极速入门Flink

969 学习 · 296 问题

查看课程