2019-10-24 11:05:59,808 DEBUG org.apache.flink.runtime.blob.BlobClient                      - PUT BLOB stream to /127.0.0.1:42382.
2019-10-24 11:05:59,824 DEBUG org.apache.flink.runtime.blob.BlobServerConnection            - Received PUT request for BLOB of job 2dee19f6a130695dc0be6f0774e1e28a with from /127.0.0.1.
2019-10-24 11:05:59,842 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Received JobGraph submission 2dee19f6a130695dc0be6f0774e1e28a (Flink Java Job at Thu Oct 24 11:05:59 UTC 2019).
2019-10-24 11:05:59,842 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Submitting job 2dee19f6a130695dc0be6f0774e1e28a (Flink Java Job at Thu Oct 24 11:05:59 UTC 2019).
2019-10-24 11:05:59,843 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_1 .
2019-10-24 11:05:59,845 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Initializing job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:05:59,847 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Using restart strategy NoRestartStrategy for Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:05:59,847 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job recovers via failover strategy: New Pipelined Region Failover
2019-10-24 11:05:59,849 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Running initialization on master for job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:05:59,857 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully ran initialization on master in 7 ms.
2019-10-24 11:05:59,858 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Adding 2 vertices from job graph Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:05:59,858 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:05:59,858 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting ExecutionJobVertex 01eec9ea7bd331e6b26d13167df638d5 (DataSource (at $line35.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat))) to 0 predecessors.
2019-10-24 11:05:59,859 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting ExecutionJobVertex e7bbaf7a09b3b489dd1c305b9c5157d8 (DataSink (org.apache.flink.api.java.Utils$CollectHelper@a492e6c)) to 1 predecessors.
2019-10-24 11:05:59,859 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Connecting input 0 of vertex e7bbaf7a09b3b489dd1c305b9c5157d8 (DataSink (org.apache.flink.api.java.Utils$CollectHelper@a492e6c)) to intermediate result referenced via predecessor 01eec9ea7bd331e6b26d13167df638d5 (DataSource (at $line35.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat))).
2019-10-24 11:05:59,859 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Start building failover regions.
2019-10-24 11:05:59,860 DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Creating a failover region with 2 vertices.
2019-10-24 11:05:59,860 INFO  org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy  - Created 1 failover regions.
2019-10-24 11:05:59,860 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully created execution graph from job graph Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:05:59,869 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManager runner for job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) was granted leadership with session id 00000000-0000-0000-0000-000000000000 at akka.tcp://flink@192.168.10.11:6123/user/jobmanager_1.
2019-10-24 11:05:59,870 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Starting execution of job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) under job master id 00000000000000000000000000000000.
2019-10-24 11:05:59,870 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) switched from state CREATED to RUNNING.
2019-10-24 11:05:59,871 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line35.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (9c06c26470fd33782bc8586f366b0044) switched from CREATED to SCHEDULED.
2019-10-24 11:05:59,871 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl     - Received slot request [SlotRequestId{5b290b8a0e4d32b4ded1f08cb7e0411e}] for task: Attempt #0 (DataSource (at $line35.$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:05:59,883 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}]
2019-10-24 11:05:59,883 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Create multi task slot [SlotRequestId{08b2e0aae281658779d0a7a60e45ed5e}] in slot [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}].
2019-10-24 11:05:59,884 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager  - Create single task slot [SlotRequestId{5b290b8a0e4d32b4ded1f08cb7e0411e}] in multi task slot [SlotRequestId{08b2e0aae281658779d0a7a60e45ed5e}] for group 01eec9ea7bd331e6b26d13167df638d5.
2019-10-24 11:05:59,885 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:05:59,885 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:05:59,891 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:05:59,893 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Resolved ResourceManager address, beginning registration
2019-10-24 11:05:59,894 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Registration at ResourceManager attempt 1 (timeout=100ms)
2019-10-24 11:05:59,900 DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService   - Add job 2dee19f6a130695dc0be6f0774e1e28a to job leader id monitoring.
2019-10-24 11:05:59,900 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:05:59,900 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Registering job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_1 for job 2dee19f6a130695dc0be6f0774e1e28a.
2019-10-24 11:05:59,901 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_1. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway.
2019-10-24 11:05:59,902 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Registered job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_1 for job 2dee19f6a130695dc0be6f0774e1e28a.
2019-10-24 11:05:59,903 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - JobManager successfully registered at ResourceManager, leader id: 00000000000000000000000000000000.
2019-10-24 11:05:59,904 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Requesting new slot [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1} from resource manager.
2019-10-24 11:05:59,905 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 2dee19f6a130695dc0be6f0774e1e28a with allocation id f53e6bda5bfc26814ef7a4719b15204f.
2019-10-24 11:06:04,254 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:04,284 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:04,289 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:04,289 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:09,905 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:06:14,265 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:14,294 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:14,295 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:14,297 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:19,926 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:06:24,285 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:24,314 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:24,315 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:24,316 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:29,945 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:06:34,306 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:34,336 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:34,338 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:34,340 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:39,965 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:06:44,326 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:44,354 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:44,355 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:44,355 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:49,984 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:06:54,334 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:54,364 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:06:54,365 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:06:54,366 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:06:59,895 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Slot Pool Status:
	status: connected to akka.tcp://flink@192.168.10.11:6123/user/resourcemanager
	registered TaskManagers: []
	available slots: []
	allocated slots: []
	pending requests: [PendingRequest{slotRequestId=SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}, resourceProfile=ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1}, allocatedSlotFuture=java.util.concurrent.CompletableFuture@185dd983[Not completed, 4 dependents]}]
	}

2019-10-24 11:06:59,994 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:04,356 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:04,384 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:04,385 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:04,385 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:10,014 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:14,375 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:14,405 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:14,405 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:14,406 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:20,034 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:24,394 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:24,424 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:24,425 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:24,426 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:30,055 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:34,414 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:34,444 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:34,445 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:34,445 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:40,078 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:44,434 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:44,464 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:44,465 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:44,465 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:50,094 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:07:54,454 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:54,485 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:07:54,486 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:07:54,487 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:07:59,914 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Slot Pool Status:
	status: connected to akka.tcp://flink@192.168.10.11:6123/user/resourcemanager
	registered TaskManagers: []
	available slots: []
	allocated slots: []
	pending requests: [PendingRequest{slotRequestId=SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}, resourceProfile=ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1}, allocatedSlotFuture=java.util.concurrent.CompletableFuture@185dd983[Not completed, 4 dependents]}]
	}

2019-10-24 11:08:00,105 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:04,475 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:04,504 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:04,505 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:04,508 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:10,124 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:14,494 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:14,524 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:14,525 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:14,526 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:20,144 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:24,505 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:24,534 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:24,536 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:24,538 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:30,165 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:34,514 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:34,544 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:34,545 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:34,546 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:40,185 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:44,535 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:44,564 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:44,565 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:44,566 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:50,204 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:08:54,544 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:54,574 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:08:54,575 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:08:54,576 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:08:59,934 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Slot Pool Status:
	status: connected to akka.tcp://flink@192.168.10.11:6123/user/resourcemanager
	registered TaskManagers: []
	available slots: []
	allocated slots: []
	pending requests: [PendingRequest{slotRequestId=SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}, resourceProfile=ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1}, allocatedSlotFuture=java.util.concurrent.CompletableFuture@185dd983[Not completed, 4 dependents]}]
	}

2019-10-24 11:09:00,225 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:04,554 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:04,584 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:04,585 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:04,586 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:10,245 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:14,575 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:14,605 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:14,606 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:14,607 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:20,265 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:24,594 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:24,624 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:24,625 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:24,626 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:30,284 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:34,619 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:34,644 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:34,645 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:34,646 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:40,305 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:44,634 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:44,666 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:44,666 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:44,667 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:50,324 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:09:54,654 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:54,685 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:09:54,686 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:09:54,687 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:09:59,944 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Slot Pool Status:
	status: connected to akka.tcp://flink@192.168.10.11:6123/user/resourcemanager
	registered TaskManagers: []
	available slots: []
	allocated slots: []
	pending requests: [PendingRequest{slotRequestId=SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}, resourceProfile=ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=-1, nativeMemoryInMB=-1, networkMemoryInMB=-1, managedMemoryInMB=-1}, allocatedSlotFuture=java.util.concurrent.CompletableFuture@185dd983[Not completed, 4 dependents]}]
	}

2019-10-24 11:10:00,345 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:04,664 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:04,694 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:04,695 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:04,696 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:10,364 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:14,674 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:14,704 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:14,705 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:14,706 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:20,385 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:24,685 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:24,715 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:24,716 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:24,717 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:30,405 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:34,704 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:34,724 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:34,724 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:34,724 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:40,424 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:44,714 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:44,734 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:44,735 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:44,736 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:50,444 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Trigger heartbeat request.
2019-10-24 11:10:54,734 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:54,754 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:10:54,756 DEBUG org.apache.flink.runtime.jobmaster.JobMaster                  - Received heartbeat request from 9fda4517a812e9fbab4284361b23ec12.
2019-10-24 11:10:54,757 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Received heartbeat from 6bd3a245bf23fde96839bab86656a95a.
2019-10-24 11:10:59,885 DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl  - Cancel slot request f53e6bda5bfc26814ef7a4719b15204f.
2019-10-24 11:10:59,886 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSource (at $line35.$read$$iw$$iw$$iw$$iw$$iw$$iw.<init>(<console>:24) (org.apache.flink.api.java.io.CollectionInputFormat)) (1/1) (9c06c26470fd33782bc8586f366b0044) switched from SCHEDULED to FAILED.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate enough slots to run the job. Please make sure that the cluster has enough resources.
	at org.apache.flink.runtime.executiongraph.Execution.lambda$scheduleForExecution$0(Execution.java:460)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl.lambda$internalAllocateSlot$0(SchedulerImpl.java:190)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$SingleTaskSlot.release(SlotSharingManager.java:700)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.release(SlotSharingManager.java:484)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.lambda$new$0(SlotSharingManager.java:380)
	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
	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 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:10:59,887 INFO  org.apache.flink.runtime.executiongraph.failover.AdaptedRestartPipelinedRegionStrategyNG  - Fail to pass the restart strategy validation in region failover. Fallback to fail global.
2019-10-24 11:10:59,887 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) switched from state RUNNING to FAILING.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate enough slots to run the job. Please make sure that the cluster has enough resources.
	at org.apache.flink.runtime.executiongraph.Execution.lambda$scheduleForExecution$0(Execution.java:460)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl.lambda$internalAllocateSlot$0(SchedulerImpl.java:190)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$SingleTaskSlot.release(SlotSharingManager.java:700)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.release(SlotSharingManager.java:484)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.lambda$new$0(SlotSharingManager.java:380)
	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
	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 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:10:59,917 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@a492e6c) (1/1) (e8dc7986a6ebae09eedf060f249ae5c3) switched from CREATED to CANCELING.
2019-10-24 11:10:59,917 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - DataSink (org.apache.flink.api.java.Utils$CollectHelper@a492e6c) (1/1) (e8dc7986a6ebae09eedf060f249ae5c3) switched from CANCELING to CANCELED.
2019-10-24 11:10:59,919 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Discarding the results produced by task execution e8dc7986a6ebae09eedf060f249ae5c3.
2019-10-24 11:10:59,930 DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph        - Try to restart or fail the job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) if no longer possible.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate enough slots to run the job. Please make sure that the cluster has enough resources.
	at org.apache.flink.runtime.executiongraph.Execution.lambda$scheduleForExecution$0(Execution.java:460)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl.lambda$internalAllocateSlot$0(SchedulerImpl.java:190)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$SingleTaskSlot.release(SlotSharingManager.java:700)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.release(SlotSharingManager.java:484)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.lambda$new$0(SlotSharingManager.java:380)
	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
	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 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:10:59,932 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) switched from state FAILING to FAILED.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate enough slots to run the job. Please make sure that the cluster has enough resources.
	at org.apache.flink.runtime.executiongraph.Execution.lambda$scheduleForExecution$0(Execution.java:460)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl.lambda$internalAllocateSlot$0(SchedulerImpl.java:190)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$SingleTaskSlot.release(SlotSharingManager.java:700)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.release(SlotSharingManager.java:484)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.lambda$new$0(SlotSharingManager.java:380)
	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
	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 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:10:59,958 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Could not restart the job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019 (2dee19f6a130695dc0be6f0774e1e28a) because the restart strategy prevented it.
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could not allocate enough slots to run the job. Please make sure that the cluster has enough resources.
	at org.apache.flink.runtime.executiongraph.Execution.lambda$scheduleForExecution$0(Execution.java:460)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl.lambda$internalAllocateSlot$0(SchedulerImpl.java:190)
	at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
	at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$SingleTaskSlot.release(SlotSharingManager.java:700)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.release(SlotSharingManager.java:484)
	at org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager$MultiTaskSlot.lambda$new$0(SlotSharingManager.java:380)
	at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822)
	at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797)
	at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
	at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
	at org.apache.flink.runtime.concurrent.FutureUtils$Timeout.run(FutureUtils.java:998)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:397)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:190)
	at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
	at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
	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 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:10:59,959 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Discarding the results produced by task execution 9c06c26470fd33782bc8586f366b0044.
2019-10-24 11:10:59,960 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Releasing slot [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}] because: java.util.concurrent.TimeoutException
2019-10-24 11:10:59,960 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Releasing slot [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}] because: Could not find task slot with SlotRequestId{08b2e0aae281658779d0a7a60e45ed5e}.
2019-10-24 11:10:59,960 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - There is no allocated slot [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}]. Ignoring the release slot request.
2019-10-24 11:10:59,960 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Pending slot request [SlotRequestId{e04dbc3c5293b969c36f7fecbd66afa4}] timed out.
2019-10-24 11:10:59,969 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Job 2dee19f6a130695dc0be6f0774e1e28a reached globally terminal state FAILED.
2019-10-24 11:10:59,979 DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Slot Pool Status:
	status: connected to akka.tcp://flink@192.168.10.11:6123/user/resourcemanager
	registered TaskManagers: []
	available slots: []
	allocated slots: []
	pending requests: []
	}

2019-10-24 11:11:00,008 INFO  org.apache.flink.runtime.history.FsJobArchivist               - Job 2dee19f6a130695dc0be6f0774e1e28a has been archived at file:/var/lib/flink/completed_jobs/2dee19f6a130695dc0be6f0774e1e28a.
2019-10-24 11:11:00,009 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Stopping the JobMaster for job Flink Java Job at Thu Oct 24 11:05:59 UTC 2019(2dee19f6a130695dc0be6f0774e1e28a).
2019-10-24 11:11:00,010 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Suspending SlotPool.
2019-10-24 11:11:00,011 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:11:00,011 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl      - Stopping SlotPool.
2019-10-24 11:11:00,011 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManagerRunner already shutdown.
2019-10-24 11:11:00,012 INFO  org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@192.168.10.11:6123/user/jobmanager_1 for job 2dee19f6a130695dc0be6f0774e1e28a from the resource manager.
2019-10-24 11:11:04,754 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:04,777 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:14,775 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:14,797 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:24,795 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:24,804 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:34,814 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:34,825 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:44,835 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:44,844 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:54,854 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:11:54,864 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:04,864 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:04,885 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:14,884 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:14,904 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:24,905 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:24,924 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.
2019-10-24 11:12:34,925 DEBUG org.apache.flink.mesos.runtime.clusterframework.MesosResourceManager  - Trigger heartbeat request.