flink.apache.org????Example
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.api.common.functions.FilterFunction;
public class Example {
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
DataStream<Person> flintstones = env.fromElements(
new Person("Fred", 35),
new Person("Wilma", 35),
new Person("Pebbles", 2));
DataStream<Person> adults = flintstones.filter(new
FilterFunction<Person>() {
@Override
public boolean filter(Person person) throws Exception {
return person.age >= 18;
}
});
adults.print();
env.execute();
}
public static class Person {
public String name;
public Integer age;
public Person() {};
public Person(String name, Integer age) {
this.name = name;
this.age = age;
};
public String toString() {
return this.name.toString() + ": age " + this.age.toString();
};
}
}
idea????????????????????????Connected to the target VM, address:
'127.0.0.1:51359', transport: 'socket' 09:51:28,058 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.cpu.cores' , default: null (fallback
keys: []) required for local execution is not set, setting it to its default
value 1.7976931348623157E308 09:51:28,077 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.memory.task.heap.size' , default: null
(fallback keys: []) required for local execution is not set, setting it to its
default value 9223372036854775807 bytes 09:51:28,078 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.memory.task.off-heap.size' , default: 0
bytes (fallback keys: []) required for local execution is not set, setting it
to its default value 9223372036854775807 bytes 09:51:28,080 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.memory.network.min' , default: 64 mb
(fallback keys: [{key=taskmanager.network.memory.min, isDeprecated=true}])
required for local execution is not set, setting it to its default value 64 mb
09:51:28,081 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.memory.network.max' , default: 1 gb
(fallback keys: [{key=taskmanager.network.memory.max, isDeprecated=true}])
required for local execution is not set, setting it to its default value 64 mb
09:51:28,082 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils [] - The
configuration option Key: 'taskmanager.memory.managed.size' , default: null
(fallback keys: [{key=taskmanager.memory.size, isDeprecated=true}]) required
for local execution is not set, setting it to its default value 128 mb
09:51:28,160 INFO org.apache.flink.runtime.minicluster.MiniCluster
[] - Starting Flink Mini Cluster 09:51:28,172 INFO
org.apache.flink.runtime.minicluster.MiniCluster [] - Starting
Metrics Registry 09:51:28,386 INFO
org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No metrics
reporter configured, no metrics will be exposed/reported. 09:51:28,386 INFO
org.apache.flink.runtime.minicluster.MiniCluster [] - Starting RPC
Service(s) 09:51:28,834 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to
start local actor system 09:51:30,907 INFO akka.event.slf4j.Slf4jLogger
[] - Slf4jLogger started 09:51:31,423 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system
started at akka://flink 09:51:31,480 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to
start local actor system 09:51:31,579 INFO akka.event.slf4j.Slf4jLogger
[] - Slf4jLogger started 09:51:31,800 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system
started at akka://flink-metrics 09:51:31,852 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at
akka://flink-metrics/user/rpc/MetricQueryService . 09:51:31,979 INFO
org.apache.flink.runtime.minicluster.MiniCluster [] - Starting
high-availability services 09:51:32,028 INFO
org.apache.flink.runtime.blob.BlobServer [] - Created BLOB
server storage directory
C:\Users\tanghong\AppData\Local\Temp\blobStore-5f32e0ad-a1e6-46a3-b28b-c61ec96cfd9f
09:51:32,057 INFO org.apache.flink.runtime.blob.BlobServer
[] - Started BLOB server at 0.0.0.0:51369 - max concurrent requests: 50 - max
backlog: 1000 09:51:32,072 INFO
org.apache.flink.runtime.blob.PermanentBlobCache [] - Created BLOB
cache storage directory
C:\Users\tanghong\AppData\Local\Temp\blobStore-14c9d617-21ad-4ed1-905a-60e882c82dd9
09:51:32,078 INFO org.apache.flink.runtime.blob.TransientBlobCache
[] - Created BLOB cache storage directory
C:\Users\tanghong\AppData\Local\Temp\blobStore-120cdc5b-e589-4084-a87a-167034e897ba
09:51:32,079 INFO org.apache.flink.runtime.minicluster.MiniCluster
[] - Starting 1 TaskManger(s) 09:51:32,092 INFO
org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - Starting
TaskManager with ResourceID: 2986f07c-d923-4c25-ab5c-db7d51e99ad0 09:51:32,250
INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices [] -
Temporary file directory 'C:\Users\tanghong\AppData\Local\Temp': total 117 GB,
usable 58 GB (49.57% usable) 09:51:32,271 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager uses directory
C:\Users\tanghong\AppData\Local\Temp\flink-io-2e42d544-6e64-4daa-896f-7eb26df53d61
for spill files. 09:51:32,309 INFO
org.apache.flink.runtime.io.disk.FileChannelManagerImpl [] -
FileChannelManager uses directory
C:\Users\tanghong\AppData\Local\Temp\flink-netty-shuffle-c65d5bf2-a3ed-463a-bc31-7fdc8c81e573
for spill files. 09:51:32,390 INFO
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool [] - Allocated 64
MB for network buffer pool (number of memory segments: 2048, bytes per segment:
32768). 09:51:32,419 INFO
org.apache.flink.runtime.io.network.NettyShuffleEnvironment [] - Starting the
network environment and its components. 09:51:32,427 INFO
org.apache.flink.runtime.taskexecutor.KvStateService [] - Starting the
kvState service and its components. 09:51:32,529 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at
akka://flink/user/rpc/taskmanager_0 . 09:51:32,587 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Start job
leader service. 09:51:32,590 INFO org.apache.flink.runtime.filecache.FileCache
[] - User file cache uses directory
C:\Users\tanghong\AppData\Local\Temp\flink-dist-cache-e27acdb4-9f35-4c83-aa8e-8276c751aba6
09:51:32,776 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
[] - Starting rest endpoint. 09:51:33,692 WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Log file
environment variable 'log.file' is not set. 09:51:33,692 WARN
org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - JobManager
log files are unavailable in the web dashboard. Log file location not found in
environment variable 'log.file' or configuration key 'web.log.path'.
09:51:33,758 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint
[] - Failed to load web based job submission extension. Probable reason:
flink-runtime-web is not in the classpath. 09:51:35,143 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Rest endpoint
listening at localhost:51404 09:51:35,145 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Proposing leadership to contender http://localhost:51404 09:51:35,159 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] -
http://localhost:51404 was granted leadership with
leaderSessionID=27555ef9-3e8f-4e95-b8d8-dde0ba310c94 09:51:35,160 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Received confirmation of leadership for leader http://localhost:51404 ,
session=27555ef9-3e8f-4e95-b8d8-dde0ba310c94 09:51:35,259 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager
at akka://flink/user/rpc/resourcemanager_1 . 09:51:35,354 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
09:51:35,355 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Proposing leadership to contender LeaderContender:
StandaloneResourceManager 09:51:35,358 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
ResourceManager akka://flink/user/rpc/resourcemanager_1 was granted leadership
with fencing token 865828ddf3546a507f0868c7b5bf4c3a 09:51:35,366 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl [] -
Starting the SlotManager. 09:51:35,372 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Start SessionDispatcherLeaderProcess. 09:51:35,375 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Recover all persisted job graphs. 09:51:35,375 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Received confirmation of leadership for leader
akka://flink/user/rpc/resourcemanager_1 ,
session=7f0868c7-b5bf-4c3a-8658-28ddf3546a50 09:51:35,376 INFO
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] -
Successfully recovered 0 persisted job graphs. 09:51:35,382 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Connecting to
ResourceManager
akka://flink/user/rpc/resourcemanager_1(865828ddf3546a507f0868c7b5bf4c3a).
09:51:35,385 INFO org.apache.flink.runtime.minicluster.MiniCluster
[] - Flink Mini Cluster started successfully 09:51:35,391 INFO
org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC
endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at
akka://flink/user/rpc/dispatcher_2 . 09:51:35,417 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Received confirmation of leadership for leader
akka://flink/user/rpc/dispatcher_2 ,
session=0e4425b7-170a-4459-b1f9-75404e402a02 09:51:35,428 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Resolved
ResourceManager address, beginning registration 09:51:35,443 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Registering TaskManager with ResourceID 2986f07c-d923-4c25-ab5c-db7d51e99ad0
(akka://flink/user/rpc/taskmanager_0) at ResourceManager 09:51:35,447 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Successful
registration at resource manager akka://flink/user/rpc/resourcemanager_1 under
registration id 9214131e1ff9f94c10db23cbdc895ad0. 09:51:35,448 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Received
JobGraph submission 74824018367ce6f9d3f1be019242b46a (Flink Streaming Job).
09:51:35,449 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher
[] - Submitting job 74824018367ce6f9d3f1be019242b46a (Flink Streaming Job).
09:51:35,493 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService
[] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at
akka://flink/user/rpc/jobmanager_3 . 09:51:35,507 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Initializing
job Flink Streaming Job (74824018367ce6f9d3f1be019242b46a). 09:51:35,533 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Using restart
back off time strategy NoRestartBackoffTimeStrategy for Flink Streaming Job
(74824018367ce6f9d3f1be019242b46a). 09:51:35,604 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Running
initialization on master for job Flink Streaming Job
(74824018367ce6f9d3f1be019242b46a). 09:51:35,604 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Successfully
ran initialization on master in 0 ms. 09:51:35,638 INFO
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology [] - Built
1 pipelined regions in 1 ms 09:51:35,666 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:35,696 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Using failover strategy
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@9a5a990
for Flink Streaming Job (74824018367ce6f9d3f1be019242b46a). 09:51:35,702 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Proposing leadership to contender akka://flink/user/rpc/jobmanager_3
09:51:35,705 INFO org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl
[] - JobManager runner for job Flink Streaming Job
(74824018367ce6f9d3f1be019242b46a) was granted leadership with session id
08ae9693-0ec5-49d7-8da6-90f9a9872d1c at akka://flink/user/rpc/jobmanager_3.
09:51:35,715 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Starting execution of job Flink Streaming Job
(74824018367ce6f9d3f1be019242b46a) under job master id
8da690f9a9872d1c08ae96930ec549d7. 09:51:35,719 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Starting
scheduling with scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategy]
09:51:35,720 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
[] - Job Flink Streaming Job (74824018367ce6f9d3f1be019242b46a) switched from
state CREATED to RUNNING. 09:51:35,735 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
CREATED to SCHEDULED. 09:51:35,735 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
CREATED to SCHEDULED. 09:51:35,735 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
CREATED to SCHEDULED. 09:51:35,736 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9) switched from
CREATED to SCHEDULED. 09:51:35,765 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Cannot serve
slot request, no ResourceManager connected. Adding as pending request
[SlotRequestId{b1b99749d1a3af19da63d2f9a43c886c}] 09:51:35,785 INFO
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
[] - Received confirmation of leadership for leader
akka://flink/user/rpc/jobmanager_3 ,
session=08ae9693-0ec5-49d7-8da6-90f9a9872d1c 09:51:35,785 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Connecting to
ResourceManager
akka://flink/user/rpc/resourcemanager_1(865828ddf3546a507f0868c7b5bf4c3a)
09:51:35,787 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Resolved ResourceManager address, beginning registration 09:51:35,791 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Registering job manager
8da690f9a9872d1c08ae96930ec549d7@akka://flink/user/rpc/jobmanager_3 for job
74824018367ce6f9d3f1be019242b46a. 09:51:35,800 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Registered job manager
8da690f9a9872d1c08ae96930ec549d7@akka://flink/user/rpc/jobmanager_3 for job
74824018367ce6f9d3f1be019242b46a. 09:51:35,803 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - JobManager
successfully registered at ResourceManager, leader id:
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,804 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{b1b99749d1a3af19da63d2f9a43c886c}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,806 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,815 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Receive slot
request fc0eafaa46685a35a94156ecbe8e8a91 for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,826 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated
slot for fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,828 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Add job
74824018367ce6f9d3f1be019242b46a for job leader monitoring. 09:51:35,832 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Try to
register at job manager akka://flink/user/rpc/jobmanager_3 with leader id
08ae9693-0ec5-49d7-8da6-90f9a9872d1c. 09:51:35,834 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Resolved
JobManager address, beginning registration 09:51:35,838 WARN
org.apache.flink.runtime.taskmanager.TaskManagerLocation [] - No hostname
could be resolved for the IP address 127.0.0.1, using IP address as host name.
Local input split assignment (such as for HDFS files) may be impacted.
09:51:35,842 INFO
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Successful
registration at job manager akka://flink/user/rpc/jobmanager_3 for job
74824018367ce6f9d3f1be019242b46a. 09:51:35,844 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Establish
JobManager connection for job 74824018367ce6f9d3f1be019242b46a. 09:51:35,852
INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,874 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Requesting new slot [SlotRequestId{12eec08ff74ff08a9a99b2131cbbd24a}] and
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,875 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,876 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{9b345ff97fcfc6caa93b0f00142d8443}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,876 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Receive slot
request 239128e310ebcdf2f28ce17cf68b083b for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,877 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated
slot for 239128e310ebcdf2f28ce17cf68b083b. 09:51:35,877 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,879 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,879 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request cf7dbb0d75022a259dab719bc343ef6b for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,879 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{2eaff8f1fa6d539bfb124a2aaa46afd6}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,880 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated
slot for cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,880 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,880 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,880 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Requesting new slot [SlotRequestId{cfbadfffb678c2c24318aa7e023d8a44}] and
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,884 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{765c41ef9466d9fe7ca028a9cb0717b6}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,885 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{5f4da62bbddcbb5fcdc3d851c4417afd}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,885 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,886 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,886 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Requesting
new slot [SlotRequestId{f6559f3d11fad8e5d5ffc97820f5f889}] and profile
ResourceProfile{UNKNOWN} from resource manager. 09:51:35,887 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
e4c7fd9f86fb37692505c272f3462065. 09:51:35,888 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. Ignoring.
09:51:35,889 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request
slot with profile ResourceProfile{UNKNOWN} for job
74824018367ce6f9d3f1be019242b46a with allocation id
c53d0733a29a09a249599c2b50258aa3. 09:51:35,892 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. Ignoring.
09:51:35,892 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b].
Ignoring. 09:51:35,893 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request 32c26f96585d3164f21d9e5fc0f2734b for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,894 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated
slot for 32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,894 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,895 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91].
Ignoring. 09:51:35,895 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. Ignoring.
09:51:35,895 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request fde097f03a36bb4a49b4dcc1ffaa85dc for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,896 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. Ignoring.
09:51:35,896 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Allocated slot for fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,896 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,897 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91].
Ignoring. 09:51:35,897 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. Ignoring.
09:51:35,897 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b].
Ignoring. 09:51:35,897 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request 24df0325dc9d490f3b82ee07dc11e3f0 for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,898 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. Ignoring.
09:51:35,898 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Allocated slot for 24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,898 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,899 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91].
Ignoring. 09:51:35,899 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request e4c7fd9f86fb37692505c272f3462065 for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,899 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. Ignoring.
09:51:35,899 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Allocated slot for e4c7fd9f86fb37692505c272f3462065. 09:51:35,899 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,900 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b].
Ignoring. 09:51:35,900 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. Ignoring.
09:51:35,901 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc].
Ignoring. 09:51:35,901 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b]. Ignoring.
09:51:35,901 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91].
Ignoring. 09:51:35,902 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. Ignoring.
09:51:35,902 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [24df0325dc9d490f3b82ee07dc11e3f0].
Ignoring. 09:51:35,902 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,902 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,902 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. Ignoring.
09:51:35,903 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
[] - Activate slot 239128e310ebcdf2f28ce17cf68b083b. 09:51:35,903 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc]. Ignoring.
09:51:35,903 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Receive slot request c53d0733a29a09a249599c2b50258aa3 for job
74824018367ce6f9d3f1be019242b46a from resource manager with leader id
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,903 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated
slot for c53d0733a29a09a249599c2b50258aa3. 09:51:35,903 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer
reserved slots to the leader of job 74824018367ce6f9d3f1be019242b46a.
09:51:35,904 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
[] - Activate slot fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,905 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,905 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,905 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,905 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
SCHEDULED to DEPLOYING. 09:51:35,906 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,906 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,906 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,906 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Source: Collection Source (1/1) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,907
INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] -
Activate slot fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,907 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
e4c7fd9f86fb37692505c272f3462065. 09:51:35,908 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,909 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,918 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,918 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
SCHEDULED to DEPLOYING. 09:51:35,918 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (1/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,921
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched
from SCHEDULED to DEPLOYING. 09:51:35,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (2/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,922
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched
from SCHEDULED to DEPLOYING. 09:51:35,923 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (3/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,924
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched
from SCHEDULED to DEPLOYING. 09:51:35,925 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (4/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,926
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) switched
from SCHEDULED to DEPLOYING. 09:51:35,926 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (5/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,927
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) switched
from SCHEDULED to DEPLOYING. 09:51:35,928 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (6/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,929
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched
from SCHEDULED to DEPLOYING. 09:51:35,929 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (7/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,929
INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter
-> Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9) switched
from SCHEDULED to DEPLOYING. 09:51:35,930 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Filter -> Sink: Print to Std. Out (8/8) (attempt #0) to
2986f07c-d923-4c25-ab5c-db7d51e99ad0 @ 127.0.0.1 (dataPort=-1) 09:51:35,930
INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] -
Received repeated offer for slot [24df0325dc9d490f3b82ee07dc11e3f0]. Ignoring.
09:51:35,930 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b].
Ignoring. 09:51:35,930 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [e4c7fd9f86fb37692505c272f3462065]. Ignoring.
09:51:35,930 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl
[] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b].
Ignoring. 09:51:35,930 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Received
repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc]. Ignoring.
09:51:35,974 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Received task Source: Collection Source (1/1). 09:51:35,976 INFO
org.apache.flink.runtime.taskmanager.Task [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
CREATED to DEPLOYING. 09:51:35,980 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
c53d0733a29a09a249599c2b50258aa3. 09:51:35,986 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Source: Collection Source (1/1)
(cf27fdfdd94b8d309f818f6fabe4a918) [DEPLOYING]. 09:51:35,989 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Source: Collection Source (1/1)
(cf27fdfdd94b8d309f818f6fabe4a918) [DEPLOYING]. 09:51:36,007 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (1/8). 09:51:36,007 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
e4c7fd9f86fb37692505c272f3462065. 09:51:36,008 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
CREATED to DEPLOYING. 09:51:36,013 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (1/8)
(63ec26a28f8b355690403c16c5c01248) [DEPLOYING]. 09:51:36,015 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (1/8)
(63ec26a28f8b355690403c16c5c01248) [DEPLOYING]. 09:51:36,022 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (2/8). 09:51:36,024 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:36,034 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
CREATED to DEPLOYING. 09:51:36,034 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (2/8)
(8435324290011c003b956e0ca887f57f) [DEPLOYING]. 09:51:36,036 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (2/8)
(8435324290011c003b956e0ca887f57f) [DEPLOYING]. 09:51:36,039 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (3/8). 09:51:36,040 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:36,043 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
CREATED to DEPLOYING. 09:51:36,044 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (3/8)
(202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,045 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (4/8). 09:51:36,045 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (3/8)
(202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,046 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
CREATED to DEPLOYING. 09:51:36,047 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (4/8)
(87aa40a14210b0bf5fc3185afb07f32a) [DEPLOYING]. 09:51:36,048 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (4/8)
(87aa40a14210b0bf5fc3185afb07f32a) [DEPLOYING]. 09:51:36,049 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:36,050 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,050 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
[] - No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880) 09:51:36,051 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,051 INFO org.apache.flink.streaming.runtime.tasks.StreamTask
[] - No state backend has been configured, using default (Memory /
JobManager) MemoryStateBackend (data in heap memory / checkpoints to
JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE,
maxStateSize: 5242880) 09:51:36,055 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (5/8). 09:51:36,056 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:36,060 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (6/8). 09:51:36,060 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,061 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
239128e310ebcdf2f28ce17cf68b083b. 09:51:36,064 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
DEPLOYING to RUNNING. 09:51:36,065 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
DEPLOYING to RUNNING. 09:51:36,066 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
DEPLOYING to RUNNING. 09:51:36,066 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
DEPLOYING to RUNNING. 09:51:36,067 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
DEPLOYING to RUNNING. 09:51:36,067 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
DEPLOYING to RUNNING. 09:51:36,068 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
DEPLOYING to RUNNING. 09:51:36,068 INFO
org.apache.flink.runtime.taskmanager.Task [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
DEPLOYING to RUNNING. 09:51:36,068 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
DEPLOYING to RUNNING. 09:51:36,060 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) switched from
CREATED to DEPLOYING. 09:51:36,069 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
DEPLOYING to RUNNING. 09:51:36,069 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (5/8)
(c43b45ca5ea59c6a262cc4b95fe318f3) [DEPLOYING]. 09:51:36,070 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) switched from
CREATED to DEPLOYING. 09:51:36,071 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (6/8)
(546ab10ef414b66815d8f9f67ca43854) [DEPLOYING]. 09:51:36,071 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (5/8)
(c43b45ca5ea59c6a262cc4b95fe318f3) [DEPLOYING]. 09:51:36,072 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,073 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Received task Filter -> Sink: Print to Std. Out (7/8).
09:51:36,073 INFO org.apache.flink.runtime.taskmanager.Task
[] - Registering task at network: Filter -> Sink: Print to Std. Out (6/8)
(546ab10ef414b66815d8f9f67ca43854) [DEPLOYING]. 09:51:36,074 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) switched from
DEPLOYING to RUNNING. 09:51:36,074 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
CREATED to DEPLOYING. 09:51:36,074 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (7/8)
(8700548cd2d3904f0d3397c01e1765ef) [DEPLOYING]. 09:51:36,075 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,075 INFO org.apache.flink.runtime.taskmanager.Task
[] - Filter -> Sink: Print to Std. Out (6/8)
(546ab10ef414b66815d8f9f67ca43854) switched from DEPLOYING to RUNNING.
09:51:36,077 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
[] - Filter -> Sink: Print to Std. Out (5/8)
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from DEPLOYING to RUNNING.
09:51:36,077 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
[] - Activate slot fc0eafaa46685a35a94156ecbe8e8a91. 09:51:36,077 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) switched from
DEPLOYING to RUNNING. 09:51:36,079 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (7/8)
(8700548cd2d3904f0d3397c01e1765ef) [DEPLOYING]. 09:51:36,080 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task
Filter -> Sink: Print to Std. Out (8/8). 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
c53d0733a29a09a249599c2b50258aa3. 09:51:36,081 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
32c26f96585d3164f21d9e5fc0f2734b. 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
e4c7fd9f86fb37692505c272f3462065. 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
cf7dbb0d75022a259dab719bc343ef6b. 09:51:36,081 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:36,082 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
DEPLOYING to RUNNING. 09:51:36,083 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
DEPLOYING to RUNNING. 09:51:36,088 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9) switched from
CREATED to DEPLOYING. 09:51:36,089 INFO
org.apache.flink.runtime.taskmanager.Task [] - Loading JAR
files for task Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9) [DEPLOYING]. 09:51:36,090 INFO
org.apache.flink.runtime.taskmanager.Task [] - Registering
task at network: Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9) [DEPLOYING]. 09:51:36,093 INFO
org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state
backend has been configured, using default (Memory / JobManager)
MemoryStateBackend (data in heap memory / checkpoints to JobManager)
(checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize:
5242880) 09:51:36,093 INFO org.apache.flink.runtime.taskmanager.Task
[] - Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9) switched from DEPLOYING to RUNNING.
09:51:36,094 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph
[] - Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9) switched from DEPLOYING to RUNNING. 8>
Wilma: age 35 7> Fred: age 35 09:51:36,234 INFO
org.apache.flink.runtime.taskmanager.Task [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
RUNNING to FINISHED. 09:51:36,234 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Source: Collection Source (1/1)
(cf27fdfdd94b8d309f818f6fabe4a918). 09:51:36,238 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Source: Collection Source (1/1) cf27fdfdd94b8d309f818f6fabe4a918.
09:51:36,239 INFO org.apache.flink.runtime.taskmanager.Task
[] - Filter -> Sink: Print to Std. Out (5/8)
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from RUNNING to FINISHED.
09:51:36,239 INFO org.apache.flink.runtime.taskmanager.Task
[] - Filter -> Sink: Print to Std. Out (6/8)
(546ab10ef414b66815d8f9f67ca43854) switched from RUNNING to FINISHED.
09:51:36,239 INFO org.apache.flink.runtime.taskmanager.Task
[] - Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9) switched from RUNNING to FINISHED.
09:51:36,239 INFO org.apache.flink.runtime.taskmanager.Task
[] - Freeing task resources for Filter -> Sink: Print to Std. Out (6/8)
(546ab10ef414b66815d8f9f67ca43854). 09:51:36,239 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
RUNNING to FINISHED. 09:51:36,240 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (4/8)
(87aa40a14210b0bf5fc3185afb07f32a). 09:51:36,240 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (5/8)
(c43b45ca5ea59c6a262cc4b95fe318f3). 09:51:36,241 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
RUNNING to FINISHED. 09:51:36,242 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (8/8)
(36d5274707b482655bb989df2d910cc9). 09:51:36,242 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
RUNNING to FINISHED. 09:51:36,242 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (3/8)
(202d4a956de7c80d8d4ed7eb6d85f122). 09:51:36,242 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
RUNNING to FINISHED. 09:51:36,243 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (2/8)
(8435324290011c003b956e0ca887f57f). 09:51:36,241 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (1/8)
(63ec26a28f8b355690403c16c5c01248). 09:51:36,243 INFO
org.apache.flink.runtime.taskmanager.Task [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
RUNNING to FINISHED. 09:51:36,244 INFO
org.apache.flink.runtime.taskmanager.Task [] - Freeing task
resources for Filter -> Sink: Print to Std. Out (7/8)
(8700548cd2d3904f0d3397c01e1765ef). 09:51:36,260 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (6/8)
546ab10ef414b66815d8f9f67ca43854. 09:51:36,261 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (4/8)
87aa40a14210b0bf5fc3185afb07f32a. 09:51:36,262 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) switched from
RUNNING to FINISHED. 09:51:36,263 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (5/8)
c43b45ca5ea59c6a262cc4b95fe318f3. 09:51:36,263 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (8/8)
36d5274707b482655bb989df2d910cc9. 09:51:36,264 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (3/8)
202d4a956de7c80d8d4ed7eb6d85f122. 09:51:36,265 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (2/8)
8435324290011c003b956e0ca887f57f. 09:51:36,265 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) switched from
RUNNING to FINISHED. 09:51:36,266 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (1/8)
63ec26a28f8b355690403c16c5c01248. 09:51:36,266 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
Un-registering task and sending final execution state FINISHED to JobManager
for task Filter -> Sink: Print to Std. Out (7/8)
8700548cd2d3904f0d3397c01e1765ef. 09:51:36,269 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a) switched from
RUNNING to FINISHED. 09:51:36,270 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) switched from
RUNNING to FINISHED. 09:51:36,271 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9) switched from
RUNNING to FINISHED. 09:51:36,272 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) switched from
RUNNING to FINISHED. 09:51:36,273 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) switched from
RUNNING to FINISHED. 09:51:36,274 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) switched from
RUNNING to FINISHED. 09:51:36,275 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Filter ->
Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) switched from
RUNNING to FINISHED. 09:51:36,275 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Streaming Job (74824018367ce6f9d3f1be019242b46a) switched from state RUNNING to
FINISHED. 09:51:36,275 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Stopping
checkpoint coordinator for job 74824018367ce6f9d3f1be019242b46a. 09:51:36,279
INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore []
- Shutting down 09:51:36,298 INFO
org.apache.flink.runtime.minicluster.MiniCluster [] - Shutting down
Flink Mini Cluster 09:51:36,299 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Shutting down
rest endpoint. 09:51:36,299 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Stopping
TaskExecutor akka://flink/user/rpc/taskmanager_0. 09:51:36,299 INFO
org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close
ResourceManager connection c853dc79e27b12d44efc839c049c59ce. 09:51:36,299 INFO
org.apache.flink.runtime.dispatcher.StandaloneDispatcher [] - Job
74824018367ce6f9d3f1be019242b46a reached globally terminal state FINISHED.
09:51:36,302 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor
[] - Close JobManager connection for job 74824018367ce6f9d3f1be019242b46a.
09:51:36,305 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Closing
TaskExecutor connection 2986f07c-d923-4c25-ab5c-db7d51e99ad0 because: The
TaskExecutor is shutting down. 09:51:36,309 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:7, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: c53d0733a29a09a249599c2b50258aa3, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,312 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:3, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: 32c26f96585d3164f21d9e5fc0f2734b, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,313 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:0, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: fc0eafaa46685a35a94156ecbe8e8a91, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,314 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:1, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: 239128e310ebcdf2f28ce17cf68b083b, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,314 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:5, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: 24df0325dc9d490f3b82ee07dc11e3f0, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,315 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:6, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: e4c7fd9f86fb37692505c272f3462065, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,315 INFO
org.apache.flink.runtime.jobmaster.JobMaster [] - Stopping the
JobMaster for job Flink Streaming Job(74824018367ce6f9d3f1be019242b46a).
09:51:36,316 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
[] - Free slot TaskSlot(index:2, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: cf7dbb0d75022a259dab719bc343ef6b, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,316 INFO
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot
TaskSlot(index:4, state:ALLOCATED, resource profile:
ResourceProfile{managedMemory=16.000mb (16777216 bytes), networkMemory=8.000mb
(8388608 bytes)}, allocationId: fde097f03a36bb4a49b4dcc1ffaa85dc, jobId:
74824018367ce6f9d3f1be019242b46a). 09:51:36,324 INFO
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] - Suspending
SlotPool. 09:51:36,325 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Close ResourceManager connection
c853dc79e27b12d44efc839c049c59ce: JobManager is shutting down.. 09:51:36,325
INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl [] -
Stopping SlotPool. 09:51:36,328 INFO
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] -
Disconnect job manager
8da690f9a9872d1c08ae96930ec549d7@akka://flink/user/rpc/jobmanager_3 for job
74824018367ce6f9d3f1be019242b46a from the resource manager. 09:51:36,369 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Removing
cache directory C:\Users\tanghong\AppData\Local\Temp\flink-web-ui 09:51:36,372
INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] -
JobManager for job 74824018367ce6f9d3f1be019242b46a with leader id
8da690f9a9872d1c08ae96930ec549d7 lost leadership. 09:51:36,376 INFO
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint [] - Shut down
complete.
