[Bug] Flink stream task start error

apache / dolphinscheduler

Apache DolphinScheduler is the modern data orchestration platform. Agile to create high performance workflow with low-code

https://dolphinscheduler.apache.org/

Apache License 2.0

12.67k stars 4.57k forks source link

[Bug] Flink stream task start error #15074

Open xiaohui2009 opened 10 months ago

xiaohui2009 commented 10 months ago

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened

创建flink stream 任务无法启动成功

What you expected to happen

master-server StreamTaskExecuteRunnable 类中 defaultTaskExecuteRunnableFactory 未初始化

How to reproduce

创建flink stream 任务无法启动

Anything else

No response

Version

3.2.x

Are you willing to submit PR?

[ ] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

github-actions[bot] commented 10 months ago

Search before asking

[X] I had searched in the issues and found no similar issues.

What happened

创建flink stream 任务无法启动成功

What you expected to happen

master-server StreamTaskExecuteRunnable 类中 defaultTaskExecuteRunnableFactory 未初始化

How to reproduce

创建flink stream 任务无法启动

Anything else

No response

Version

3.2.x

Are you willing to submit PR?

[ ] Yes I am willing to submit a PR!

Code of Conduct

[X] I agree to follow this project's Code of Conduct

SherlockXian commented 10 months ago

我也碰到一样的问题，创建Flink Stream的节点启动后虽然会显示成功，但是节点没有日志，也看不到Job生成。如果用普通的Flink去跑Flink Stream的Job在几分钟后会自动关闭

calm-projects commented 10 months ago

flink stream task 在任务--->任务定义中点击运行，才会在yarn上执行，但是感觉很多功能未完善，无法监控任务是否运行，无法设置保存点，无法停止任务。

wangrui93lx commented 5 months ago

mee too

xbyang18 commented 2 months ago

一样，defaultTaskExecuteRunnableFactory 这个没有设置值， this.defaultTaskExecuteRunnableFactory = SpringApplicationContext.getBean(DefaultTaskExecuteRunnableFactory.class); 我是standlane上跑，看页面好像只能在yarn上？哪里设置-m jobmanager-url 了