Task is always created state after submit a example job

[Lei Wang]

flink 1.11.2 on a single host. 

./bin/start-cluster.sh and then 

./bin/flink run examples/streaming/SocketWindowWordCount.jar  --hostname localhost --port 1111

But on the jobmanager UI, the task is always in created state.  There's available  slots. 

Any insights on this?

Thanks,

Lei

[Piotr Nowojski-4]

Hi,

I would start by looking at the Job Manager and Task Manager logs. Take a look if Task Managers connected/registered in the Job Manager and if so, if there were no problems when submitting the job. It seems like either there are not enough slots, or slots are actually not available. 

Best,

Piotrek

pt., 18 cze 2021 o 05:53 Lei Wang <[hidden email]> napisał(a):

flink 1.11.2 on a single host. 

./bin/start-cluster.sh and then 

./bin/flink run examples/streaming/SocketWindowWordCount.jar  --hostname localhost --port 1111

But on the jobmanager UI, the task is always in created state.  There's available  slots. 

Any insights on this?

Thanks,

Lei

[Lei Wang]

There's enough slots on the jobmanger UI, but the slots are not available.

After i add  taskmanager.host: localhost to flink-conf.yaml, it works.

But i don't know why. 

Thanks,
Lei

On Fri, Jun 18, 2021 at 6:07 PM Piotr Nowojski <[hidden email]> wrote:

Hi,

I would start by looking at the Job Manager and Task Manager logs. Take a look if Task Managers connected/registered in the Job Manager and if so, if there were no problems when submitting the job. It seems like either there are not enough slots, or slots are actually not available. 

Best,

Piotrek

pt., 18 cze 2021 o 05:53 Lei Wang <[hidden email]> napisał(a):

flink 1.11.2 on a single host. 

./bin/start-cluster.sh and then 

./bin/flink run examples/streaming/SocketWindowWordCount.jar  --hostname localhost --port 1111

But on the jobmanager UI, the task is always in created state.  There's available  slots. 

Any insights on this?

Thanks,

Lei