2017-10-02 10:51:28,023 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - JobManager akka.tcp://flink@xxxxxxxxx103.tail_of_hostname:6123/user/jobmanager was granted leadership with leader session ID Some(661d24c7-xxxx-4d15-8583-efd2ee3c2e3b). 2017-10-02 10:51:28,032 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Delaying recovery of all jobs by 10000 milliseconds. 2017-10-02 10:51:28,041 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://flink@xxxxxxxxx103.tail_of_hostname:6123/user/jobmanager:661d24c7-xxxx-4d15-8583-efd2ee3c2e3b. 2017-10-02 10:51:28,044 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Trying to associate with JobManager leader akka.tcp://flink@xxxxxxxxx103.tail_of_hostname:6123/user/jobmanager 2017-10-02 10:51:28,051 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#923003410] - leader session 661d24c7-xxxx-4d15-8583-efd2ee3c2e3b 2017-10-02 10:51:28,176 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Scheduling Mesos task taskmanager-00001 with (1024.0 MB, 1.0 cpus). 2017-10-02 10:51:28,193 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Scheduling Mesos task taskmanager-00002 with (1024.0 MB, 1.0 cpus). 2017-10-02 10:51:28,195 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Now gathering offers for at least 2 task(s). 2017-10-02 10:51:28,207 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Received offer(s) of 252958.0 MB, 61.25 cpus: 2017-10-02 10:51:28,208 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 18f3d9d0-7982-491a-8397-0e799272fd2d-O1246 from xxxxxxxxx101.tail_of_hostname of 127375.0 MB, 31.5 cpus 2017-10-02 10:51:28,208 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 18f3d9d0-7982-491a-8397-0e799272fd2d-O1247 from xxxxxxxxx103.tail_of_hostname of 125583.0 MB, 29.75 cpus 2017-10-02 10:51:29,225 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 2 new offer(s) plus outstanding offers. 2017-10-02 10:51:29,241 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:51:29,243 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 125583.0 MB, 29.75 cpus 2017-10-02 10:51:29,243 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 127375.0 MB, 31.5 cpus 2017-10-02 10:51:29,413 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Launched 2 task(s) on xxxxxxxxx101.tail_of_hostname using 1 offer(s): 2017-10-02 10:51:29,413 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 18f3d9d0-7982-491a-8397-0e799272fd2d-O1246 2017-10-02 10:51:29,414 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - No longer gathering offers; all requests fulfilled. 2017-10-02 10:51:29,414 INFO com.netflix.fenzo.TaskScheduler - Expiring all leases 2017-10-02 10:51:29,415 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Declined offer 18f3d9d0-7982-491a-8397-0e799272fd2d-O1247 from xxxxxxxxx103.tail_of_hostname of 125583.0 MB, 29.75 cpus. 2017-10-02 10:51:29,518 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Launching Mesos task taskmanager-00002 on host xxxxxxxxx101.tail_of_hostname. 2017-10-02 10:51:29,571 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Launching Mesos task taskmanager-00001 on host xxxxxxxxx101.tail_of_hostname. 2017-10-02 10:51:32,487 INFO org.apache.flink.mesos.scheduler.TaskMonitor - Mesos task taskmanager-00002 is running. 2017-10-02 10:51:32,821 INFO org.apache.flink.mesos.scheduler.TaskMonitor - Mesos task taskmanager-00001 is running. 2017-10-02 10:51:35,118 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - TaskManager taskmanager-00002 has started. 2017-10-02 10:51:35,123 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at xxxxxxxxx101 (akka.tcp://flink@xxxxxxxxx101.tail_of_hostname:31002/user/taskmanager) as a8c1e687923c9649c27145797d1796c5. Current number of registered hosts is 1. Current number of alive task slots is 32. 2017-10-02 10:51:35,362 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - TaskManager taskmanager-00001 has started. 2017-10-02 10:51:35,362 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at xxxxxxxxx101 (akka.tcp://flink@xxxxxxxxx101.tail_of_hostname:31000/user/taskmanager) as 50111f20b91ef30e6bba43bf2058b6d4. Current number of registered hosts is 2. Current number of alive task slots is 64. 2017-10-02 10:51:38,045 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Attempting to recover all jobs. 2017-10-02 10:51:38,051 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - There are no jobs to recover.