Hi, that helped however there is a problem with JobStatus. Please refer to [1]
In my case JobStatus is already Running but not all task are running. Any idea how to get task status from MiniCluster? [1] http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Issue-with-job-status-td36068.html#none -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/