Hi Prasanna,
The job failed because it fails to acquire enough slots to run tasks.
Did you launch any task manager?
The JobNotFound exception is thrown because someone(possibly Flink UI)
sends a query for a job that does not exist in the Flink cluster.
>From the log you attached, the job id of yo
Hi ,
I am running flink locally in my machine with following configurations.
# The RPC port where the JobManager is reachable.
jobmanager.rpc.port: 6123
# The heap size for the JobManager JVM
jobmanager.heap.size: 1024m
# The heap size for the TaskManager JVM
taskmanager.heap.size: 1024m
