Search before asking
What happened
ds version
flink version
Flink Stream startup error: Master dispatch task to worker error
[WI-0][TI-0] - [INFO] 2026-04-30 16:42:16.234 +0800 o.a.d.s.m.r.StreamingTaskOperatorImpl:[45] - Receive triggerStreamingTask request: StreamingTaskTriggerRequest(executorId=1, executorName=admin, projectCode=13607458212416, taskDefinitionCode=21506564609472, taskDefinitionVersion=1, warningGroupId=0, workerGroup=default, environmentCode=-1, startParams=null, tenantCode=default, dryRun=0)
[WI-0][TI-0] - [INFO] 2026-04-30 16:42:16.239 +0800 o.a.d.s.p.ProcessServiceImpl:[1308] - updated resource info {"id":null,"resourceName":"file:/dolphinscheduler/dolphinscheduler/resources/FlinkTest-1.0-SNAPSHOT.jar","res":null}
[WI-0][TI-0] - [ERROR] 2026-04-30 16:42:16.245 +0800 o.a.d.s.m.r.StreamTaskExecuteRunnable:[153] - Master dispatch task to worker error, taskInstanceName: flink_stream_test
java.lang.NullPointerException: null
at org.apache.dolphinscheduler.server.master.runner.StreamTaskExecuteRunnable.run(StreamTaskExecuteRunnable.java:150)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)What you expected to happen
How to reproduce
Create a Flink stream real-time task, click "Run", and view the master log. An error will appear saying "Master dispatch task to worker"
Anything else
No response
Version
dev
Are you willing to submit PR?
Code of Conduct
Search before asking
What happened
ds version
flink version
Flink Stream startup error: Master dispatch task to worker error
[WI-0][TI-0] - [INFO] 2026-04-30 16:42:16.234 +0800 o.a.d.s.m.r.StreamingTaskOperatorImpl:[45] - Receive triggerStreamingTask request: StreamingTaskTriggerRequest(executorId=1, executorName=admin, projectCode=13607458212416, taskDefinitionCode=21506564609472, taskDefinitionVersion=1, warningGroupId=0, workerGroup=default, environmentCode=-1, startParams=null, tenantCode=default, dryRun=0) [WI-0][TI-0] - [INFO] 2026-04-30 16:42:16.239 +0800 o.a.d.s.p.ProcessServiceImpl:[1308] - updated resource info {"id":null,"resourceName":"file:/dolphinscheduler/dolphinscheduler/resources/FlinkTest-1.0-SNAPSHOT.jar","res":null} [WI-0][TI-0] - [ERROR] 2026-04-30 16:42:16.245 +0800 o.a.d.s.m.r.StreamTaskExecuteRunnable:[153] - Master dispatch task to worker error, taskInstanceName: flink_stream_test java.lang.NullPointerException: null at org.apache.dolphinscheduler.server.master.runner.StreamTaskExecuteRunnable.run(StreamTaskExecuteRunnable.java:150) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748)What you expected to happen
How to reproduce
Create a Flink stream real-time task, click "Run", and view the master log. An error will appear saying "Master dispatch task to worker"
Anything else
No response
Version
dev
Are you willing to submit PR?
Code of Conduct