2017-10-02 10:33:02,006 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - JobManager akka.tcp://flink@xxxxxxxxx101.tail_of_hostname:6123/user/jobmanager was granted leadership with leader session ID Some(d862154d-xxxx-48e7-876d-90c709a34f9c). 2017-10-02 10:33:02,015 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Delaying recovery of all jobs by 10000 milliseconds. 2017-10-02 10:33:02,018 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://flink@xxxxxxxxx101.tail_of_hostname:6123/user/jobmanager:d862154d-xxxx-48e7-876d-90c709a34f9c. 2017-10-02 10:33:02,029 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Trying to associate with JobManager leader akka.tcp://flink@xxxxxxxxx101.tail_of_hostname:6123/user/jobmanager 2017-10-02 10:33:02,034 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#-698489119] - leader session d862154d-xxxx-48e7-876d-90c709a34f9c 2017-10-02 10:33:02,102 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Scheduling Mesos task taskmanager-00001 with (1024.0 MB, 1.0 cpus). 2017-10-02 10:33:02,119 INFO org.apache.flink.mesos.runtime.clusterframework.MesosFlinkResourceManager - Scheduling Mesos task taskmanager-00002 with (1024.0 MB, 1.0 cpus). 2017-10-02 10:33:02,121 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Now gathering offers for at least 2 task(s). 2017-10-02 10:33:02,133 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Received offer(s) of 252958.0 MB, 61.25 cpus: 2017-10-02 10:33:02,134 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 18f3d9d0-7982-491a-8397-0e799272fd2d-O1224 from xxxxxxxxx101.tail_of_hostname of 126351.0 MB, 30.5 cpus 2017-10-02 10:33:02,134 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - 18f3d9d0-7982-491a-8397-0e799272fd2d-O1225 from xxxxxxxxx103.tail_of_hostname of 126607.0 MB, 30.75 cpus 2017-10-02 10:33:03,149 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 2 new offer(s) plus outstanding offers. 2017-10-02 10:33:03,311 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:03,314 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:03,314 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:03,317 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:08,328 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:08,331 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:08,331 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:08,331 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:08,332 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:12,030 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - Attempting to recover all jobs. 2017-10-02 10:33:12,033 INFO org.apache.flink.mesos.runtime.clusterframework.MesosJobManager - There are no jobs to recover. 2017-10-02 10:33:13,348 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:13,350 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:13,351 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:13,351 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:13,351 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:18,368 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:18,370 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:18,370 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:18,371 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:18,371 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:23,388 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:23,390 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:23,390 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:23,391 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:23,391 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:28,408 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:28,410 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:28,410 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:28,411 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:28,411 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:33,428 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:33,430 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:33,430 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:33,431 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:33,432 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:38,448 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:38,450 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:38,451 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:38,451 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:38,452 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:43,468 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:43,470 INFO com.netflix.fenzo.TaskScheduler - Purging inactive VMs 2017-10-02 10:33:43,471 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:43,471 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx-slave103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:43,471 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx-slave101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:43,471 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:48,488 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:48,491 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:48,491 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:48,491 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:48,492 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:53,508 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:53,511 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:53,511 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:53,511 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:53,512 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:33:58,528 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:33:58,530 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:33:58,531 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:33:58,531 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:33:58,531 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:34:03,548 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:34:03,550 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:34:03,551 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:34:03,551 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:34:03,552 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched. 2017-10-02 10:34:08,568 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Processing 2 task(s) against 0 new offer(s) plus outstanding offers. 2017-10-02 10:34:08,570 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Resources considered: (note: expired offers not deducted from below) 2017-10-02 10:34:08,570 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx103.tail_of_hostname has 126607.0 MB, 30.75 cpus 2017-10-02 10:34:08,571 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - xxxxxxxxx101.tail_of_hostname has 126351.0 MB, 30.5 cpus 2017-10-02 10:34:08,571 INFO org.apache.flink.mesos.scheduler.LaunchCoordinator - Waiting for more offers; 2 task(s) are not yet launched.