2019-10-24 11:02:03,844 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:03,855 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:10,821 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf  - -Dorg.apache.flink.shaded.netty4.io.netty.buffer.checkAccessible: true
2019-10-24 11:02:10,825 DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.AbstractByteBuf  - -Dorg.apache.flink.shaded.netty4.io.netty.buffer.checkBounds: true
2019-10-24 11:02:10,827 DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetectorFactory  - Loaded default ResourceLeakDetector: org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector@6b76f897
2019-10-24 11:02:10,861 DEBUG org.apache.flink.shaded.netty4.io.netty.util.Recycler         - -Dio.netty.recycler.maxCapacityPerThread: 4096
2019-10-24 11:02:10,861 DEBUG org.apache.flink.shaded.netty4.io.netty.util.Recycler         - -Dio.netty.recycler.maxSharedCapacityFactor: 2
2019-10-24 11:02:10,862 DEBUG org.apache.flink.shaded.netty4.io.netty.util.Recycler         - -Dio.netty.recycler.linkCapacity: 16
2019-10-24 11:02:10,862 DEBUG org.apache.flink.shaded.netty4.io.netty.util.Recycler         - -Dio.netty.recycler.ratio: 8
2019-10-24 11:02:11,161 DEBUG org.apache.flink.runtime.blob.BlobClient                      - PUT BLOB stream to /127.0.0.1:42346.
2019-10-24 11:02:11,164 DEBUG org.apache.flink.runtime.blob.BlobServerConnection            - Received PUT request for BLOB of job 43ab5669d3290e3d1c27541dbe5b3e57 with from /127.0.0.1.
2019-10-24 11:02:11,182 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Received JobGraph submission 43ab5669d3290e3d1c27541dbe5b3e57 (Flink Java Job at Thu Oct 24 11:02:10 UTC 2019).
2019-10-24 11:02:11,183 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Submitting job 43ab5669d3290e3d1c27541dbe5b3e57 (Flink Java Job at Thu Oct 24 11:02:10 UTC 2019).
2019-10-24 11:02:11,219 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_0 .
2019-10-24 11:02:11,234 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Initializing job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:11,268 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Using restart strategy NoRestartStrategy for Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:11,305 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job recovers via failover strategy: New Pipelined Region Failover
2019-10-24 11:02:11,329 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Running initialization on master for job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:11,366 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully ran initialization on master in 36 ms.
2019-10-24 11:02:11,366 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Adding 2 vertices from job graph Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:11,366 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Attaching 2 topologically sorted vertices to existing job graph with 0 vertices and 0 intermediate results.
2019-10-24 11:02:11,380 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting ExecutionJobVertex dcbc5853e2a8cc868d8836f504f2ebc5 (DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat))) to 0 predecessors.
2019-10-24 11:02:11,381 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting ExecutionJobVertex 0f70aacf650d84d2e455aec7d5742401 (DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4)) to 1 predecessors.
2019-10-24 11:02:11,382 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting input 0 of vertex 0f70aacf650d84d2e455aec7d5742401 (DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4)) to intermediate result referenced via predecessor dcbc5853e2a8cc868d8836f504f2ebc5 (DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat))).
2019-10-24 11:02:11,401 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Start building failover regions.
2019-10-24 11:02:11,402 DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Creating a failover region with 2 vertices.
2019-10-24 11:02:11,404 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Created 1 failover regions.
2019-10-24 11:02:11,420 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully created execution graph from job graph Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:11,430 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManager runner for job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57) was granted leadership with session id 00000000-0000-0000-0000-000000000000 at akka.tcp://flink@192.168.10.11:6123/user/jobmanager_0.
2019-10-24 11:02:11,438 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Starting execution of job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57) under job master id 00000000000000000000000000000000.
2019-10-24 11:02:11,443 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57) switched from state CREATED to RUNNING.
2019-10-24 11:02:11,452 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (2f03e75bbaa607f98a9fda26031ee3ef) switched from CREATED to SCHEDULED.
2019-10-24 11:02:11,468 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl     - Received slot request [SlotRequestId{2298fd508b59dd8ce30e49e60eee30f9}] for task: Attempt #0 (DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1)) @ (unassigned) - [SCHEDULED]
2019-10-24 11:02:11,521 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{8791b319fe69c2c029b5370c8786381d}]
2019-10-24 11:02:11,535 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Create multi task slot [SlotRequestId{263f6f519fa917210750d1cbdfecf5e5}] in slot [SlotRequestId{8791b319fe69c2c029b5370c8786381d}].
2019-10-24 11:02:11,538 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Create single task slot [SlotRequestId{2298fd508b59dd8ce30e49e60eee30f9}] in multi task slot [SlotRequestId{263f6f519fa917210750d1cbdfecf5e5}] for group dcbc5853e2a8cc868d8836f504f2ebc5.
2019-10-24 11:02:11,573 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:02:11,575 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Connecting to ResourceManager akka.tcp://flink@192.168.10.11:6123/user/resourcemanager(00000000000000000000000000000000)
2019-10-24 11:02:11,578 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.11:6123/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway.
2019-10-24 11:02:11,579 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Resolved ResourceManager address, beginning registration
2019-10-24 11:02:11,579 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Registration at ResourceManager attempt 1 (timeout=100ms)
2019-10-24 11:02:11,581 DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService   - Add job 43ab5669d3290e3d1c27541dbe5b3e57 to job leader id monitoring.
2019-10-24 11:02:11,583 DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService   - Found a new job leader 00000000-0000-0000-0000-000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager.
2019-10-24 11:02:11,586 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Registering job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_0 for job 43ab5669d3290e3d1c27541dbe5b3e57.
2019-10-24 11:02:11,589 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.11:6123/user/jobmanager_0. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway.
2019-10-24 11:02:11,603 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Registered job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_0 for job 43ab5669d3290e3d1c27541dbe5b3e57.
2019-10-24 11:02:11,606 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - JobManager successfully registered at ResourceManager, leader id: 00000000000000000000000000000000.
2019-10-24 11:02:11,607 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Requesting new slot [SlotRequestId{8791b319fe69c2c029b5370c8786381d}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1} from resource manager.
2019-10-24 11:02:11,609 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1} for job 43ab5669d3290e3d1c27541dbe5b3e57 with allocation id fe1fc4fb6c39d08eb5b401467d78750a.
2019-10-24 11:02:11,610 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Starting a new worker.
2019-10-24 11:02:11,619 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - LaunchableMesosWorker parameters: MesosTaskManagerParameters{cpus=2.0, gpus=0, containerType=DOCKER, containerImageName=Some(eskimo:flink-worker), containeredParameters=TaskManagerParameters {totalContainerMemory=1024, taskManagerHeapSize=360, taskManagerDirectMemoryLimit=664, numSlots=1, taskManagerEnv={}}, containerVolumes=[container_path: "/var/log/flink"
host_path: "/var/log/flink"
mode: RW
, container_path: "/var/lib/flink"
host_path: "/var/lib/flink"
mode: RW
, container_path: "/host_etc"
host_path: "/etc"
mode: RO
], dockerParameters=[], dockerForcePullImage=false, constraints=[], taskManagerHostName=None, command=$FLINK_HOME/bin/mesos-taskmanager.sh, bootstrapCommand=Some(export FLINK_HOME=/usr/local/lib/flink/), uris=[]}
2019-10-24 11:02:11,624 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Scheduling Mesos task taskmanager-00001 with (1024.0 MB, 2.0 cpus).
2019-10-24 11:02:11,636 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Now gathering offers for at least 1 task(s).
2019-10-24 11:02:11,664 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - State change (Idle -> GatheringOffers) with data GatherData(List(LaunchableMesosWorker{taskID=value: "taskmanager-00001"
taskRequest=Request{cpus=2.0, memory=1024.0, gpus=0.0}}),List())
2019-10-24 11:02:11,681 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Received offer(s) of 9432.0 MB, 4.0 cpus, 0.0 gpus:
2019-10-24 11:02:11,689 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - State change (Suspended -> Suspended) with data StateData(New(value: "taskmanager-00001"
))
2019-10-24 11:02:11,692 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - State change (Suspended -> New) with data StateData(New(value: "taskmanager-00001"
))
2019-10-24 11:02:11,691 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            -   048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O10 from 192.168.10.13 of 4639.0 MB, 2.0 cpus, 0.0 gpus for [*]
2019-10-24 11:02:11,694 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            -   048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O11 from 192.168.10.14 of 4793.0 MB, 2.0 cpus, 0.0 gpus for [*]
2019-10-24 11:02:12,715 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Processing 1 task(s) against 2 new offer(s) plus outstanding offers.
2019-10-24 11:02:12,723 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - 192.168.10.13: adding lease offer id 048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O10
2019-10-24 11:02:12,723 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - 192.168.10.14: adding lease offer id 048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O11
2019-10-24 11:02:12,724 DEBUG com.netflix.fenzo.AssignableVMs                               - Host 192.168.10.13 available for assignments
2019-10-24 11:02:12,724 DEBUG com.netflix.fenzo.AssignableVMs                               - Host 192.168.10.14 available for assignments
2019-10-24 11:02:12,724 DEBUG com.netflix.fenzo.TaskScheduler                               - Found 2 VMs with non-zero offers to assign from
2019-10-24 11:02:12,725 DEBUG com.netflix.fenzo.TaskScheduler                               - Launching 1 threads for evaluating assignments for task taskmanager-00001
2019-10-24 11:02:12,726 DEBUG com.netflix.fenzo.TaskScheduler                               - Evaluting task assignment on host 192.168.10.13
2019-10-24 11:02:12,727 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - Host 192.168.10.13 task taskmanager-00001: #leases=1
2019-10-24 11:02:12,729 DEBUG com.netflix.fenzo.TaskScheduler                               - Evaluting task assignment on host 192.168.10.14
2019-10-24 11:02:12,729 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - Host 192.168.10.14 task taskmanager-00001: #leases=1
2019-10-24 11:02:12,730 DEBUG com.netflix.fenzo.TaskScheduler                               - Task taskmanager-00001: best result so far: TaskAssignmentResult{host=192.168.10.14, request=Request{cpus=2.0, memory=1024.0, gpus=0.0}, taskId='taskmanager-00001', hostname='192.168.10.14', assignedPorts=[], successful=true, failures=null, constraintFailure=null, fitness=0.85}
2019-10-24 11:02:12,730 DEBUG com.netflix.fenzo.TaskScheduler                               - Task taskmanager-00001: found successful assignment on host 192.168.10.14
2019-10-24 11:02:12,731 INFO  com.netflix.fenzo.TaskScheduler                               - Purging inactive VMs
2019-10-24 11:02:12,731 INFO  com.netflix.fenzo.AssignableVMs                               - Removed inactive host 192.168.10.14
2019-10-24 11:02:12,731 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Resources considered: (note: expired offers not deducted from below)
2019-10-24 11:02:12,733 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            -   192.168.10.13 has 4639.0 MB, 2.0 cpus, null gpus
2019-10-24 11:02:12,776 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - SchedulingResult{resultMap={192.168.10.14=VMAssignmentResult{hostname='192.168.10.14', leasesUsed=[Offer{offer=id {
  value: "048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O11"
}
framework_id {
  value: "048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-0003"
}
slave_id {
  value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
}
hostname: "192.168.10.14"
resources {
  name: "cpus"
  type: SCALAR
  scalar {
    value: 2.0
  }
  role: "*"
}
resources {
  name: "mem"
  type: SCALAR
  scalar {
    value: 4793.0
  }
  role: "*"
}
resources {
  name: "disk"
  type: SCALAR
  scalar {
    value: 34940.0
  }
  role: "*"
}
resources {
  name: "ports"
  type: RANGES
  ranges {
    range {
      begin: 31000
      end: 32000
    }
  }
  role: "*"
}
url {
  scheme: "http"
  address {
    hostname: "192.168.10.14"
    ip: "192.168.10.14"
    port: 5051
  }
  path: "/slave(1)"
}
, resources='[cpus(*):2.0; mem(*):4793.0; disk(*):34940.0; ports(*):[31000-32000]]', hostname='192.168.10.14', vmID='8977e508-0698-4c40-9317-cdc3cc8982f4-S1', attributeMap={}, offeredTime=1571914931678}], tasksAssigned=[TaskAssignmentResult{host=192.168.10.14, request=Request{cpus=2.0, memory=1024.0, gpus=0.0}, taskId='taskmanager-00001', hostname='192.168.10.14', assignedPorts=[31000, 31001], successful=true, failures=null, constraintFailure=null, fitness=0.85}]}}, failures={}, leasesAdded=2, leasesRejected=0, runtime=8, numAllocations=2, totalVMsCount=2, idleVMsCount=1}
2019-10-24 11:02:12,789 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - Assigning resources: [cpus(*):2.0; mem(*):4793.0; disk(*):34940.0; ports(*):[31000-32000]]
2019-10-24 11:02:12,823 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - Processing task taskmanager-00001
2019-10-24 11:02:12,850 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocating 2.0 cpus
2019-10-24 11:02:12,851 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Taking 2.0 from cpus(*):2.0
2019-10-24 11:02:12,852 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocated: [cpus(*):2.0], unsatisfied: 0.0
2019-10-24 11:02:12,853 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocating 0.0 gpus
2019-10-24 11:02:12,853 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocated: [], unsatisfied: 0.0
2019-10-24 11:02:12,854 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocating 1024.0 mem
2019-10-24 11:02:12,855 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Taking 1024.0 from mem(*):4793.0
2019-10-24 11:02:12,855 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocated: [mem(*):1024.0], unsatisfied: 0.0
2019-10-24 11:02:12,860 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocating 2 ports
2019-10-24 11:02:12,861 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Taking [31000-31001] from ports(*):[31000-32000]
2019-10-24 11:02:12,862 DEBUG org.apache.flink.mesos.util.MesosResourceAllocation           - Allocated: [ports(*):[31000-31001]], unsatisfied: 0
2019-10-24 11:02:12,897 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - Remaining resources: [mem(*):3769.0; disk(*):34940.0; ports(*):[31002-32000]]
2019-10-24 11:02:12,900 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - Assigned task taskmanager-00001 to host 192.168.10.14.
2019-10-24 11:02:12,902 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - 192.168.10.14: setting assigned task taskmanager-00001
2019-10-24 11:02:12,903 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Launching Mesos task taskmanager-00001 on host 192.168.10.14.
2019-10-24 11:02:12,905 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - State change (New -> Staging) with data StateData(Launched(value: "taskmanager-00001"
,value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
))
2019-10-24 11:02:12,912 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Launched 1 task(s) on 192.168.10.14 using 1 offer(s):
2019-10-24 11:02:12,913 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            -   048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O11
2019-10-24 11:02:12,914 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - No longer gathering offers; all requests fulfilled.
2019-10-24 11:02:12,917 INFO  com.netflix.fenzo.TaskScheduler                               - Expiring all leases
2019-10-24 11:02:12,917 DEBUG com.netflix.fenzo.AssignableVirtualMachine                    - 192.168.10.13: expiring lease offer id 048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O10
2019-10-24 11:02:12,918 INFO  org.apache.flink.mesos.scheduler.LaunchCoordinator            - Declined offer 048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-O10 from 192.168.10.13 of 4639.0 MB, 2.0 cpus.
2019-10-24 11:02:12,921 DEBUG com.netflix.fenzo.AssignableVMs                               - Host 192.168.10.13 not available for assignments
2019-10-24 11:02:12,921 DEBUG com.netflix.fenzo.AssignableVMs                               - Host 192.168.10.14 not available for assignments
2019-10-24 11:02:12,922 DEBUG com.netflix.fenzo.TaskScheduler                               - Found 0 VMs with non-zero offers to assign from
2019-10-24 11:02:12,922 DEBUG org.apache.flink.mesos.scheduler.LaunchCoordinator            - State change (GatheringOffers -> Idle) with data GatherData(List(),List())
2019-10-24 11:02:12,979 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/taskmanager.sh'
2019-10-24 11:02:12,982 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/pyflink-gateway-server.sh'
2019-10-24 11:02:12,984 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-taskmanager.sh'
2019-10-24 11:02:12,989 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink.bat'
2019-10-24 11:02:12,988 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/historyserver.sh'
2019-10-24 11:02:12,996 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink-console.sh'
2019-10-24 11:02:12,997 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/yarn-session.sh'
2019-10-24 11:02:12,999 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-appmaster-job.sh'
2019-10-24 11:02:13,011 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/jobmanager.sh'
2019-10-24 11:02:13,008 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/find-flink-home.sh'
2019-10-24 11:02:13,022 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/pyflink-shell.sh'
2019-10-24 11:02:13,025 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-appmaster.sh'
2019-10-24 11:02:13,012 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/stop-zookeeper-quorum.sh'
2019-10-24 11:02:13,029 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/stop-cluster.sh'
2019-10-24 11:02:13,034 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/zookeeper.sh'
2019-10-24 11:02:13,037 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/config.sh'
2019-10-24 11:02:13,038 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/sql-client.sh'
2019-10-24 11:02:13,041 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-scala-shell.sh'
2019-10-24 11:02:13,044 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink'
2019-10-24 11:02:13,046 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink-daemon.sh'
2019-10-24 11:02:13,051 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/zoo.cfg'
2019-10-24 11:02:13,056 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-cluster.sh'
2019-10-24 11:02:13,058 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-cli.properties'
2019-10-24 11:02:13,071 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/slaves'
2019-10-24 11:02:13,075 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-zookeeper-quorum.sh'
2019-10-24 11:02:13,076 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-cluster.bat'
2019-10-24 11:02:13,077 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/bin/standalone-job.sh'
2019-10-24 11:02:13,078 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-console.properties'
2019-10-24 11:02:13,080 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/sql-client-defaults.yaml'
2019-10-24 11:02:13,080 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/flink-conf.yaml'
2019-10-24 11:02:13,082 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback-yarn.xml'
2019-10-24 11:02:13,079 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/masters'
2019-10-24 11:02:13,085 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j.properties'
2019-10-24 11:02:13,088 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-yarn-session.properties'
2019-10-24 11:02:13,089 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback-console.xml'
2019-10-24 11:02:13,092 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/slf4j-log4j12-1.7.15.jar'
2019-10-24 11:02:13,093 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-avro-1.9.1.jar'
2019-10-24 11:02:13,095 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-table_2.11-1.9.1.jar'
2019-10-24 11:02:13,096 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-csv-1.9.1.jar'
2019-10-24 11:02:13,098 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback.xml'
2019-10-24 11:02:13,097 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-shaded-hadoop-2-uber-2.8.3-7.0.jar'
2019-10-24 11:02:13,101 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-json-1.9.1.jar'
2019-10-24 11:02:13,107 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-dist_2.11-1.9.1.jar'
2019-10-24 11:02:13,107 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/log4j-1.2.17.jar'
2019-10-24 11:02:13,109 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-table-blink_2.11-1.9.1.jar'
2019-10-24 11:02:13,114 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - HEAD request for file 'file:/usr/local/lib/flink-1.9.1/plugins/README.txt'
2019-10-24 11:02:13,267 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-cluster.bat'
2019-10-24 11:02:13,279 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-table_2.11-1.9.1.jar'
2019-10-24 11:02:13,569 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/stop-cluster.sh'
2019-10-24 11:02:13,578 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/pyflink-shell.sh'
2019-10-24 11:02:13,594 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-zookeeper-quorum.sh'
2019-10-24 11:02:13,603 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/sql-client.sh'
2019-10-24 11:02:13,612 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-scala-shell.sh'
2019-10-24 11:02:13,621 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/stop-zookeeper-quorum.sh'
2019-10-24 11:02:13,626 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-appmaster.sh'
2019-10-24 11:02:13,631 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/find-flink-home.sh'
2019-10-24 11:02:13,643 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/jobmanager.sh'
2019-10-24 11:02:13,647 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-table-blink_2.11-1.9.1.jar'
2019-10-24 11:02:13,792 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/config.sh'
2019-10-24 11:02:13,796 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/taskmanager.sh'
2019-10-24 11:02:13,804 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-taskmanager.sh'
2019-10-24 11:02:13,809 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/historyserver.sh'
2019-10-24 11:02:13,813 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/zookeeper.sh'
2019-10-24 11:02:13,825 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/mesos-appmaster-job.sh'
2019-10-24 11:02:13,842 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/start-cluster.sh'
2019-10-24 11:02:13,846 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink'
2019-10-24 11:02:13,853 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink-daemon.sh'
2019-10-24 11:02:13,859 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink-console.sh'
2019-10-24 11:02:13,864 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/standalone-job.sh'
2019-10-24 11:02:13,865 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:13,872 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-yarn-session.properties'
2019-10-24 11:02:13,877 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:13,879 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/sql-client-defaults.yaml'
2019-10-24 11:02:13,880 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:02:13,880 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 4cd7c1b76a68bf57ef7ff3ee457037ea.
2019-10-24 11:02:13,893 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback.xml'
2019-10-24 11:02:13,897 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-json-1.9.1.jar'
2019-10-24 11:02:13,905 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback-console.xml'
2019-10-24 11:02:13,909 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/slf4j-log4j12-1.7.15.jar'
2019-10-24 11:02:13,916 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-avro-1.9.1.jar'
2019-10-24 11:02:13,923 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-shaded-hadoop-2-uber-2.8.3-7.0.jar'
2019-10-24 11:02:14,321 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-csv-1.9.1.jar'
2019-10-24 11:02:14,328 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/zoo.cfg'
2019-10-24 11:02:14,345 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/log4j-1.2.17.jar'
2019-10-24 11:02:14,373 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/lib/flink-dist_2.11-1.9.1.jar'
2019-10-24 11:02:14,913 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/slaves'
2019-10-24 11:02:14,921 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/flink-conf.yaml'
2019-10-24 11:02:14,941 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/masters'
2019-10-24 11:02:14,950 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/logback-yarn.xml'
2019-10-24 11:02:14,962 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-cli.properties'
2019-10-24 11:02:14,973 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/plugins/README.txt'
2019-10-24 11:02:14,991 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/yarn-session.sh'
2019-10-24 11:02:14,997 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j.properties'
2019-10-24 11:02:15,012 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/pyflink-gateway-server.sh'
2019-10-24 11:02:15,024 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/conf/log4j-console.properties'
2019-10-24 11:02:15,035 DEBUG org.apache.flink.mesos.util.MesosArtifactServer               - GET request for file 'file:/usr/local/lib/flink-1.9.1/bin/flink.bat'
2019-10-24 11:02:15,496 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - Status update received for Mesos task taskmanager-00001: StatusUpdate{status=task_id {
  value: "taskmanager-00001"
}
state: TASK_STARTING
slave_id {
  value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
}
timestamp: 1.571914935439526E9
executor_id {
  value: "taskmanager-00001"
}
source: SOURCE_EXECUTOR
uuid: "HA\377\257\305\031Ed\256\346Yv/\310S\273"
container_status {
  network_infos {
    ip_addresses {
      ip_address: "192.168.10.14"
    }
  }
  4: "\n$f9ac048f-bfc7-4522-a57a-4ee1d739e795"
}
}
2019-10-24 11:02:15,506 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - State change (Staging -> Staging) with data StateData(Launched(value: "taskmanager-00001"
,value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
))
2019-10-24 11:02:18,154 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - Status update received for Mesos task taskmanager-00001: StatusUpdate{status=task_id {
  value: "taskmanager-00001"
}
state: TASK_RUNNING
data: "[\n    {\n        \"Id\": \"3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00\",\n        \"Created\": \"2019-10-24T11:02:15.516490794Z\",\n        \"Path\": \"/bin/sh\",\n        \"Args\": [\n            \"-c\",\n            \"export FLINK_HOME=/usr/local/lib/flink/ && $FLINK_HOME/bin/mesos-taskmanager.sh -Dtaskmanager.data.port=31000 -Dtaskmanager.rpc.port=31001\"\n        ],\n        \"State\": {\n            \"Status\": \"running\",\n            \"Running\": true,\n            \"Paused\": false,\n            \"Restarting\": false,\n            \"OOMKilled\": false,\n            \"Dead\": false,\n            \"Pid\": 14733,\n            \"ExitCode\": 0,\n            \"Error\": \"\",\n            \"StartedAt\": \"2019-10-24T11:02:17.702970109Z\",\n            \"FinishedAt\": \"0001-01-01T00:00:00Z\"\n        },\n        \"Image\": \"sha256:13a1c6db34a8fb8e37951e8dbfc4dd02dfd606a19355721c598752aebaebba96\",\n        \"ResolvConfPath\": \"/var/lib/docker/containers/3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00/resolv.conf\",\n        \"HostnamePath\": \"/var/lib/docker/containers/3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00/hostname\",\n        \"HostsPath\": \"/var/lib/docker/containers/3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00/hosts\",\n        \"LogPath\": \"/var/lib/docker/containers/3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00/3de3a398b3cb3c703d46f8044b0d89310e7597e6347b3834403aa970dec23c00-json.log\",\n        \"Name\": \"/mesos-f9ac048f-bfc7-4522-a57a-4ee1d739e795\",\n        \"RestartCount\": 0,\n        \"Driver\": \"overlay2\",\n        \"Platform\": \"linux\",\n        \"MountLabel\": \"\",\n        \"ProcessLabel\": \"\",\n        \"AppArmorProfile\": \"\",\n        \"ExecIDs\": null,\n        \"HostConfig\": {\n            \"Binds\": [\n                \"/var/lib/mesos/slave/slaves/8977e508-0698-4c40-9317-cdc3cc8982f4-S1/frameworks/048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-0003/executors/taskmanager-00001/runs/f9ac048f-bfc7-4522-a57a-4ee1d739e795:/mnt/mesos/sandbox\",\n                \"/var/log/flink:/var/log/flink:rw\",\n                \"/var/lib/flink:/var/lib/flink:rw\",\n                \"/etc:/host_etc:ro\"\n            ],\n            \"ContainerIDFile\": \"\",\n            \"LogConfig\": {\n                \"Type\": \"json-file\",\n                \"Config\": {}\n            },\n            \"NetworkMode\": \"host\",\n            \"PortBindings\": {},\n            \"RestartPolicy\": {\n                \"Name\": \"no\",\n                \"MaximumRetryCount\": 0\n            },\n            \"AutoRemove\": false,\n            \"VolumeDriver\": \"\",\n            \"VolumesFrom\": null,\n            \"CapAdd\": null,\n            \"CapDrop\": null,\n            \"Capabilities\": null,\n            \"Dns\": [],\n            \"DnsOptions\": [],\n            \"DnsSearch\": [],\n            \"ExtraHosts\": null,\n            \"GroupAdd\": null,\n            \"IpcMode\": \"private\",\n            \"Cgroup\": \"\",\n            \"Links\": null,\n            \"OomScoreAdj\": 0,\n            \"PidMode\": \"\",\n            \"Privileged\": false,\n            \"PublishAllPorts\": false,\n            \"ReadonlyRootfs\": false,\n            \"SecurityOpt\": null,\n            \"UTSMode\": \"\",\n            \"UsernsMode\": \"\",\n            \"ShmSize\": 67108864,\n            \"Runtime\": \"runc\",\n            \"ConsoleSize\": [\n                0,\n                0\n            ],\n            \"Isolation\": \"\",\n            \"CpuShares\": 2048,\n            \"Memory\": 1073741824,\n            \"NanoCpus\": 0,\n            \"CgroupParent\": \"\",\n            \"BlkioWeight\": 0,\n            \"BlkioWeightDevice\": [],\n            \"BlkioDeviceReadBps\": null,\n            \"BlkioDeviceWriteBps\": null,\n            \"BlkioDeviceReadIOps\": null,\n            \"BlkioDeviceWriteIOps\": null,\n            \"CpuPeriod\": 0,\n            \"CpuQuota\": 0,\n            \"CpuRealtimePeriod\": 0,\n            \"CpuRealtimeRuntime\": 0,\n            \"CpusetCpus\": \"\",\n            \"CpusetMems\": \"\",\n            \"Devices\": [],\n            \"DeviceCgroupRules\": null,\n            \"DeviceRequests\": null,\n            \"KernelMemory\": 0,\n            \"KernelMemoryTCP\": 0,\n            \"MemoryReservation\": 0,\n            \"MemorySwap\": 2147483648,\n            \"MemorySwappiness\": null,\n            \"OomKillDisable\": false,\n            \"PidsLimit\": null,\n            \"Ulimits\": null,\n            \"CpuCount\": 0,\n            \"CpuPercent\": 0,\n            \"IOMaximumIOps\": 0,\n            \"IOMaximumBandwidth\": 0,\n            \"MaskedPaths\": [\n                \"/proc/asound\",\n                \"/proc/acpi\",\n                \"/proc/kcore\",\n                \"/proc/keys\",\n                \"/proc/latency_stats\",\n                \"/proc/timer_list\",\n                \"/proc/timer_stats\",\n                \"/proc/sched_debug\",\n                \"/proc/scsi\",\n                \"/sys/firmware\"\n            ],\n            \"ReadonlyPaths\": [\n                \"/proc/bus\",\n                \"/proc/fs\",\n                \"/proc/irq\",\n                \"/proc/sys\",\n                \"/proc/sysrq-trigger\"\n            ]\n        },\n        \"GraphDriver\": {\n            \"Data\": {\n                \"LowerDir\": \"/var/lib/docker/overlay2/ea5be7e283df7f752a8d6e0252a440cbcc54cfaf3218a94d18af6abf592dd3b8-init/diff:/var/lib/docker/overlay2/4f586fad26a948e9e325c8fd783ddc402b9cde318692c7d81e3ee103ef985f5b/diff:/var/lib/docker/overlay2/86aac9f54a3fac5cfd25bcf332444b4ff1576b47d3edbc014c552008b3c4f6e7/diff:/var/lib/docker/overlay2/e0be684a79c9e3764c420cb85653dbde45b41ce8206829b1d8489270fc7c788f/diff:/var/lib/docker/overlay2/34aca3141b3e7565a29c8179a889bc81667e7009fd1cbbc23f61be2cb10c5149/diff\",\n                \"MergedDir\": \"/var/lib/docker/overlay2/ea5be7e283df7f752a8d6e0252a440cbcc54cfaf3218a94d18af6abf592dd3b8/merged\",\n                \"UpperDir\": \"/var/lib/docker/overlay2/ea5be7e283df7f752a8d6e0252a440cbcc54cfaf3218a94d18af6abf592dd3b8/diff\",\n                \"WorkDir\": \"/var/lib/docker/overlay2/ea5be7e283df7f752a8d6e0252a440cbcc54cfaf3218a94d18af6abf592dd3b8/work\"\n            },\n            \"Name\": \"overlay2\"\n        },\n        \"Mounts\": [\n            {\n                \"Type\": \"bind\",\n                \"Source\": \"/etc\",\n                \"Destination\": \"/host_etc\",\n                \"Mode\": \"ro\",\n                \"RW\": false,\n                \"Propagation\": \"rprivate\"\n            },\n            {\n                \"Type\": \"bind\",\n                \"Source\": \"/var/lib/mesos/slave/slaves/8977e508-0698-4c40-9317-cdc3cc8982f4-S1/frameworks/048e8ebb-5bb3-4b9b-84aa-7f4893ccf99c-0003/executors/taskmanager-00001/runs/f9ac048f-bfc7-4522-a57a-4ee1d739e795\",\n                \"Destination\": \"/mnt/mesos/sandbox\",\n                \"Mode\": \"\",\n                \"RW\": true,\n                \"Propagation\": \"rprivate\"\n            },\n            {\n                \"Type\": \"bind\",\n                \"Source\": \"/var/log/flink\",\n                \"Destination\": \"/var/log/flink\",\n                \"Mode\": \"rw\",\n                \"RW\": true,\n                \"Propagation\": \"rprivate\"\n            },\n            {\n                \"Type\": \"bind\",\n                \"Source\": \"/var/lib/flink\",\n                \"Destination\": \"/var/lib/flink\",\n                \"Mode\": \"rw\",\n                \"RW\": true,\n                \"Propagation\": \"rprivate\"\n            }\n        ],\n        \"Config\": {\n            \"Hostname\": \"cent-node2\",\n            \"Domainname\": \"\",\n            \"User\": \"\",\n            \"AttachStdin\": false,\n            \"AttachStdout\": true,\n            \"AttachStderr\": true,\n            \"ExposedPorts\": {\n                \"6121/tcp\": {},\n                \"6122/tcp\": {}\n            },\n            \"Tty\": false,\n            \"OpenStdin\": false,\n            \"StdinOnce\": false,\n            \"Env\": [\n                \"HADOOP_USER_NAME=flink\",\n                \"JVM_ARGS= -Xms360m -Xmx360m -XX:MaxDirectMemorySize=664m \",\n                \"MESOS_CONTAINER_NAME=mesos-f9ac048f-bfc7-4522-a57a-4ee1d739e795\",\n                \"MESOS_SANDBOX=/mnt/mesos/sandbox\",\n                \"TASK_NAME=taskmanager-00001\",\n                \"_FLINK_CONTAINER_ID=taskmanager-00001\",\n                \"FLINK_HOME=flink\",\n                \"FRAMEWORK_NAME=Flink\",\n                \"PATH=/usr/local/sbin:/usr/local/bin:/usr/sbin:/usr/bin:/sbin:/bin\"\n            ],\n            \"Cmd\": [\n                \"-c\",\n                \"export FLINK_HOME=/usr/local/lib/flink/ && $FLINK_HOME/bin/mesos-taskmanager.sh -Dtaskmanager.data.port=31000 -Dtaskmanager.rpc.port=31001\"\n            ],\n            \"Image\": \"eskimo:flink-worker\",\n            \"Volumes\": null,\n            \"WorkingDir\": \"\",\n            \"Entrypoint\": [\n                \"/bin/sh\"\n            ],\n            \"OnBuild\": null,\n            \"Labels\": {}\n        },\n        \"NetworkSettings\": {\n            \"Bridge\": \"\",\n            \"SandboxID\": \"f81f804d3aa4a51845460d018cf3b76c0823c7f70fa625b0ecbb7a9d65051bc6\",\n            \"HairpinMode\": false,\n            \"LinkLocalIPv6Address\": \"\",\n            \"LinkLocalIPv6PrefixLen\": 0,\n            \"Ports\": {},\n            \"SandboxKey\": \"/var/run/docker/netns/default\",\n            \"SecondaryIPAddresses\": null,\n            \"SecondaryIPv6Addresses\": null,\n            \"EndpointID\": \"\",\n            \"Gateway\": \"\",\n            \"GlobalIPv6Address\": \"\",\n            \"GlobalIPv6PrefixLen\": 0,\n            \"IPAddress\": \"\",\n            \"IPPrefixLen\": 0,\n            \"IPv6Gateway\": \"\",\n            \"MacAddress\": \"\",\n            \"Networks\": {\n                \"host\": {\n                    \"IPAMConfig\": null,\n                    \"Links\": null,\n                    \"Aliases\": null,\n                    \"NetworkID\": \"8d800483a159ed0076c54dda76f715a311d2567bea8e31277720cb143625540b\",\n                    \"EndpointID\": \"ad7cfc8be67fa72e2f3cc2f3f98fbf666ab561ff4f4968ab2f57374b009727c6\",\n                    \"Gateway\": \"\",\n                    \"IPAddress\": \"\",\n                    \"IPPrefixLen\": 0,\n                    \"IPv6Gateway\": \"\",\n                    \"GlobalIPv6Address\": \"\",\n                    \"GlobalIPv6PrefixLen\": 0,\n                    \"MacAddress\": \"\",\n                    \"DriverOpts\": null\n                }\n            }\n        }\n    }\n]\n"
slave_id {
  value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
}
timestamp: 1.571914938131606E9
executor_id {
  value: "taskmanager-00001"
}
source: SOURCE_EXECUTOR
uuid: ".6\334\333\201\323E\243\207O\250\332\376\266@\227"
container_status {
  network_infos {
    ip_addresses {
      ip_address: "192.168.10.14"
    }
  }
  4: "\n$f9ac048f-bfc7-4522-a57a-4ee1d739e795"
}
}
2019-10-24 11:02:18,155 INFO  org.apache.flink.mesos.scheduler.TaskMonitor                  - Mesos task taskmanager-00001 is running.
2019-10-24 11:02:18,155 DEBUG org.apache.flink.mesos.scheduler.TaskMonitor                  - State change (Staging -> Running) with data StateData(Launched(value: "taskmanager-00001"
,value: "8977e508-0698-4c40-9317-cdc3cc8982f4-S1"
))
2019-10-24 11:02:21,595 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:02:21,628 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.14:31001/user/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway.
2019-10-24 11:02:21,690 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Registering TaskManager with ResourceID taskmanager-00001 (akka.tcp://flink@192.168.10.14:31001/user/taskmanager_0) at ResourceManager
2019-10-24 11:02:21,774 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl  - Registering TaskManager taskmanager-00001 under cd3dfdb4536c880a88de0ddfe8307225 at the SlotManager.
2019-10-24 11:02:21,949 DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Try to connect to remote RPC endpoint with address akka.tcp://flink@192.168.10.14:31001/user/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway.
2019-10-24 11:02:21,970 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Register new TaskExecutor taskmanager-00001.
2019-10-24 11:02:21,997 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Not all requests are fulfilled due to over-allocated, number of requests is 1, number of evicted requests is 0, underlying allocated is ResourceProfile{cpuCores=1.7976931348623157E308, heapMemoryInMB=2147483647, directMemoryInMB=2147483647, nativeMemoryInMB=2147483647, networkMemoryInMB=2147483647, managedMemoryInMB=230}, fulfilled is ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1}, evicted requests is [],
2019-10-24 11:02:22,026 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (2f03e75bbaa607f98a9fda26031ee3ef) switched from SCHEDULED to DEPLOYING.
2019-10-24 11:02:22,027 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (attempt #0) to taskmanager-00001 @ 192.168.10.14 (dataPort=31000)
2019-10-24 11:02:22,055 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Fulfilled slot request [SlotRequestId{8791b319fe69c2c029b5370c8786381d}] with allocated slot [fe1fc4fb6c39d08eb5b401467d78750a].
2019-10-24 11:02:22,207 DEBUG org.apache.flink.runtime.blob.BlobServerConnection            - Received GET request for BLOB 43ab5669d3290e3d1c27541dbe5b3e57/p-b354be122424b20ba6b6aedb2c66a90d031ef9c4-2403fc0402309abd462b77111ae5687d from /192.168.10.14.
2019-10-24 11:02:22,345 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (2f03e75bbaa607f98a9fda26031ee3ef) switched from DEPLOYING to RUNNING.
2019-10-24 11:02:22,484 DEBUG org.apache.flink.api.common.io.DefaultInputSplitAssigner      - Assigning split GenericSplit (0/1) to 192.168.10.14
2019-10-24 11:02:22,484 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Send next input split GenericSplit (0/1).
2019-10-24 11:02:22,514 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) (7f8ae6f6aeab1a896bf651084e8ff10b) switched from CREATED to SCHEDULED.
2019-10-24 11:02:22,516 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl     - Received slot request [SlotRequestId{9d9d3bac900708866b9f556491b5abef}] for task: Attempt #0 (DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1)) @ (unassigned) - [SCHEDULED]
2019-10-24 11:02:22,520 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Create single task slot [SlotRequestId{9d9d3bac900708866b9f556491b5abef}] in multi task slot [SlotRequestId{263f6f519fa917210750d1cbdfecf5e5}] for group 0f70aacf650d84d2e455aec7d5742401.
2019-10-24 11:02:22,526 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) (7f8ae6f6aeab1a896bf651084e8ff10b) switched from SCHEDULED to DEPLOYING.
2019-10-24 11:02:22,527 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) (attempt #0) to taskmanager-00001 @ 192.168.10.14 (dataPort=31000)
2019-10-24 11:02:22,530 DEBUG org.apache.flink.api.common.io.DefaultInputSplitAssigner      - No more input splits available
2019-10-24 11:02:22,531 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Send next input split null.
2019-10-24 11:02:22,664 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (2f03e75bbaa607f98a9fda26031ee3ef) switched from RUNNING to FINISHED.
2019-10-24 11:02:22,665 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Ignoring transition of vertex DataSource (at $line27.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) - execution #0 to FAILED while being FINISHED.
2019-10-24 11:02:22,678 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) (7f8ae6f6aeab1a896bf651084e8ff10b) switched from DEPLOYING to RUNNING.
2019-10-24 11:02:22,706 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) (7f8ae6f6aeab1a896bf651084e8ff10b) switched from RUNNING to FINISHED.
2019-10-24 11:02:22,706 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Ignoring transition of vertex DataSink (org.apache.flink.api.java.Utils$CollectHelper@3668dfe4) (1/1) - execution #0 to FAILED while being FINISHED.
2019-10-24 11:02:22,708 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Releasing slot [SlotRequestId{8791b319fe69c2c029b5370c8786381d}] because: Release multi task slot because all children have been released.
2019-10-24 11:02:22,710 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Adding returned slot [fe1fc4fb6c39d08eb5b401467d78750a] to available slots
2019-10-24 11:02:22,716 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019 (43ab5669d3290e3d1c27541dbe5b3e57) switched from state RUNNING to FINISHED.
2019-10-24 11:02:22,756 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Job 43ab5669d3290e3d1c27541dbe5b3e57 reached globally terminal state FINISHED.
2019-10-24 11:02:23,215 INFO  org.apache.flink.runtime.history.FsJobArchivist               - Job 43ab5669d3290e3d1c27541dbe5b3e57 has been archived at file:/var/lib/flink/completed_jobs/43ab5669d3290e3d1c27541dbe5b3e57.
2019-10-24 11:02:23,229 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Stopping the JobMaster for job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019(43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:23,229 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Disconnect TaskExecutor taskmanager-00001 because: Stopping JobMaster for job Flink Java Job at Thu Oct 24 11:02:10 UTC 2019(43ab5669d3290e3d1c27541dbe5b3e57).
2019-10-24 11:02:23,243 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Suspending SlotPool.
2019-10-24 11:02:23,244 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Close ResourceManager connection 9fda4517a812e9fbab4284361b23ec12.
org.apache.flink.util.FlinkException: JobManager is shutting down.
	at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:347)
	at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
	at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
	at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
	at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
	at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
	at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
	at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
	at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
	at akka.actor.ActorCell.invoke(ActorCell.scala:561)
	at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
	at akka.dispatch.Mailbox.run(Mailbox.scala:225)
	at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
	at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
	at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
	at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
	at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
2019-10-24 11:02:23,248 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_0 for job 43ab5669d3290e3d1c27541dbe5b3e57 from the resource manager.
2019-10-24 11:02:23,248 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Stopping SlotPool.
2019-10-24 11:02:23,253 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManagerRunner already shutdown.
2019-10-24 11:02:23,885 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:23,895 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:02:23,933 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from taskmanager-00001.
2019-10-24 11:02:23,934 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl  - Received slot report from instance cd3dfdb4536c880a88de0ddfe8307225: SlotReport{slotsStatus=[SlotStatus{slotID=taskmanager-00001_0, resourceProfile=ResourceProfile{cpuCores=1.7976931348623157E308, heapMemoryInMB=2147483647, directMemoryInMB=2147483647, nativeMemoryInMB=2147483647, networkMemoryInMB=2147483647, managedMemoryInMB=230}, allocationID=null, jobID=null}]}.