??????no print

jacky-cui Mon, 10 Aug 2020 20:58:09 -0700

????????????????????????????flink??????1.10??????????????????????????????????????????????????
6&gt; Wilma: age 35
5&gt; Fred: age 35




??????flink??????????


------------------&nbsp;????????&nbsp;------------------
??????:                                                                         
                                               "user-zh"                        
                                                            
<[email protected]&gt;;
????????:&nbsp;2020??8??11??(??????) ????11:30
??????:&nbsp;"user-zh"<[email protected]&gt;;

????:&nbsp;no print



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 {

&nbsp;&nbsp;&nbsp; public static void main(String[] args) throws Exception {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; final StreamExecutionEnvironment env 
=
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 StreamExecutionEnvironment.getExecutionEnvironment();

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DataStream<Person&amp;gt; 
flintstones = env.fromElements(
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 new Person("Fred", 35),
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 new Person("Wilma", 35),
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 new Person("Pebbles", 2));

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; DataStream<Person&amp;gt; adults = 
flintstones.filter(new FilterFunction<Person&amp;gt;() {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; @Override
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public 
boolean filter(Person person) throws Exception {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 return person.age &amp;gt;= 18;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; }
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; });

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; adults.print();

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; env.execute();
&nbsp;&nbsp;&nbsp; }

&nbsp;&nbsp;&nbsp; public static class Person {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public String name;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public Integer age;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public Person() {};

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public Person(String name, Integer 
age) {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.name = 
name;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; this.age = 
age;
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; };

&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; public String toString() {
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; return 
this.name.toString() + ": age " + this.age.toString();
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; };
&nbsp;&nbsp;&nbsp; }
}
idea????????????????????????Connected to the target VM, address: 
'127.0.0.1:51359', transport: 'socket' 09:51:28,058 INFO&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting Flink Mini Cluster 09:51:28,172 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting Metrics Registry 09:51:28,386 INFO&nbsp; 
org.apache.flink.runtime.metrics.MetricRegistryImpl&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - No metrics reporter configured, no metrics will be exposed/reported. 
09:51:28,386 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC Service(s) 09:51:28,834 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Trying to start local actor system 09:51:30,907 INFO&nbsp; 
akka.event.slf4j.Slf4jLogger&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Slf4jLogger started 09:51:31,423 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Actor system started at akka://flink 09:51:31,480 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Trying to start local actor system 09:51:31,579 INFO&nbsp; 
akka.event.slf4j.Slf4jLogger&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Slf4jLogger started 09:51:31,800 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Actor system started at akka://flink-metrics 09:51:31,852 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC endpoint for 
org.apache.flink.runtime.metrics.dump.MetricQueryService at 
akka://flink-metrics/user/rpc/MetricQueryService . 09:51:31,979 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting high-availability services 09:51:32,028 INFO&nbsp; 
org.apache.flink.runtime.blob.BlobServer&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Created BLOB server storage directory 
C:\Users\tanghong\AppData\Local\Temp\blobStore-5f32e0ad-a1e6-46a3-b28b-c61ec96cfd9f
 09:51:32,057 INFO&nbsp; 
org.apache.flink.runtime.blob.BlobServer&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Started BLOB server at 0.0.0.0:51369 - max concurrent requests: 50 - max 
backlog: 1000 09:51:32,072 INFO&nbsp; 
org.apache.flink.runtime.blob.PermanentBlobCache&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Created BLOB cache storage directory 
C:\Users\tanghong\AppData\Local\Temp\blobStore-14c9d617-21ad-4ed1-905a-60e882c82dd9
 09:51:32,078 INFO&nbsp; 
org.apache.flink.runtime.blob.TransientBlobCache&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Created BLOB cache storage directory 
C:\Users\tanghong\AppData\Local\Temp\blobStore-120cdc5b-e589-4084-a87a-167034e897ba
 09:51:32,079 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting 1 TaskManger(s) 09:51:32,092 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskManagerRunner&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting TaskManager with ResourceID: 
2986f07c-d923-4c25-ab5c-db7d51e99ad0 09:51:32,250 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskManagerServices&nbsp;&nbsp;&nbsp; [] 
- Temporary file directory 'C:\Users\tanghong\AppData\Local\Temp': total 117 
GB, usable 58 GB (49.57% usable) 09:51:32,271 INFO&nbsp; 
org.apache.flink.runtime.io.disk.FileChannelManagerImpl&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - FileChannelManager uses directory 
C:\Users\tanghong\AppData\Local\Temp\flink-io-2e42d544-6e64-4daa-896f-7eb26df53d61
 for spill files. 09:51:32,309 INFO&nbsp; 
org.apache.flink.runtime.io.disk.FileChannelManagerImpl&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
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&nbsp; 
org.apache.flink.runtime.io.network.NettyShuffleEnvironment&nbsp; [] - Starting 
the network environment and its components. 09:51:32,427 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.KvStateService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting the kvState service and its components. 09:51:32,529 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC endpoint for 
org.apache.flink.runtime.taskexecutor.TaskExecutor at 
akka://flink/user/rpc/taskmanager_0 . 09:51:32,587 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Start job 
leader service. 09:51:32,590 INFO&nbsp; 
org.apache.flink.runtime.filecache.FileCache&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - User file cache uses directory 
C:\Users\tanghong\AppData\Local\Temp\flink-dist-cache-e27acdb4-9f35-4c83-aa8e-8276c751aba6
 09:51:32,776 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Starting rest endpoint. 09:51:33,692 WARN&nbsp; 
org.apache.flink.runtime.webmonitor.WebMonitorUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Log file environment variable 'log.file' is not set. 09:51:33,692 
WARN&nbsp; 
org.apache.flink.runtime.webmonitor.WebMonitorUtils&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Failed to load web based job submission extension. Probable reason: 
flink-runtime-web is not in the classpath. 09:51:35,143 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Rest endpoint listening at localhost:51404 09:51:35,145 INFO&nbsp; 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
[] - Proposing leadership to contender http://localhost:51404 09:51:35,159 
INFO&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
http://localhost:51404 was granted leadership with 
leaderSessionID=27555ef9-3e8f-4e95-b8d8-dde0ba310c94 09:51:35,160 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC endpoint for 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at 
akka://flink/user/rpc/resourcemanager_1 . 09:51:35,354 INFO&nbsp; 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
[] - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner 
09:51:35,355 INFO&nbsp; 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
[] - Proposing leadership to contender LeaderContender: 
StandaloneResourceManager 09:51:35,358 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl [] - 
Starting the SlotManager. 09:51:35,372 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Start SessionDispatcherLeaderProcess. 09:51:35,375 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Recover all persisted job graphs. 09:51:35,375 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - 
Successfully recovered 0 persisted job graphs. 09:51:35,382 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Connecting to ResourceManager 
akka://flink/user/rpc/resourcemanager_1(865828ddf3546a507f0868c7b5bf4c3a). 
09:51:35,385 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Flink Mini Cluster started successfully 09:51:35,391 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC endpoint for 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher at 
akka://flink/user/rpc/dispatcher_2 . 09:51:35,417 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Resolved ResourceManager address, beginning registration 09:51:35,443 
INFO&nbsp; 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&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Successful registration at resource manager 
akka://flink/user/rpc/resourcemanager_1 under registration id 
9214131e1ff9f94c10db23cbdc895ad0. 09:51:35,448 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received JobGraph submission 74824018367ce6f9d3f1be019242b46a (Flink 
Streaming Job). 09:51:35,449 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Submitting job 74824018367ce6f9d3f1be019242b46a (Flink Streaming Job). 
09:51:35,493 INFO&nbsp; 
org.apache.flink.runtime.rpc.akka.AkkaRpcService&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at 
akka://flink/user/rpc/jobmanager_3 . 09:51:35,507 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Initializing job Flink Streaming Job (74824018367ce6f9d3f1be019242b46a). 
09:51:35,533 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Using restart back off time strategy NoRestartBackoffTimeStrategy for 
Flink Streaming Job (74824018367ce6f9d3f1be019242b46a). 09:51:35,604 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Running initialization on master for job Flink Streaming Job 
(74824018367ce6f9d3f1be019242b46a). 09:51:35,604 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Successfully ran initialization on master in 0 ms. 09:51:35,638 
INFO&nbsp; org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology 
[] - Built 1 pipelined regions in 1 ms 09:51:35,666 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Using failover strategy 
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@9a5a990
 for Flink Streaming Job (74824018367ce6f9d3f1be019242b46a). 09:51:35,702 
INFO&nbsp; 
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService 
[] - Proposing leadership to contender akka://flink/user/rpc/jobmanager_3 
09:51:35,705 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting execution of job Flink Streaming Job 
(74824018367ce6f9d3f1be019242b46a) under job master id 
8da690f9a9872d1c08ae96930ec549d7. 09:51:35,719 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Starting scheduling with scheduling strategy 
[org.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategy] 
09:51:35,720 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Job Flink Streaming Job (74824018367ce6f9d3f1be019242b46a) switched from 
state CREATED to RUNNING. 09:51:35,735 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from CREATED to SCHEDULED. 09:51:35,735 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from CREATED to SCHEDULED. 
09:51:35,735 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from CREATED to SCHEDULED. 
09:51:35,736 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from CREATED to SCHEDULED. 
09:51:35,765 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Cannot serve slot request, no ResourceManager connected. Adding as 
pending request [SlotRequestId{b1b99749d1a3af19da63d2f9a43c886c}] 09:51:35,785 
INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Connecting to ResourceManager 
akka://flink/user/rpc/resourcemanager_1(865828ddf3546a507f0868c7b5bf4c3a) 
09:51:35,787 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Resolved ResourceManager address, beginning registration 09:51:35,791 
INFO&nbsp; org.apache.flink.runtime.resourcemanager.StandaloneResourceManager 
[] - Registering job manager 
8da690f9a9872d1c08ae96930ec549d7@akka://flink/user/rpc/jobmanager_3 for job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,800 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - 
Registered job manager 
8da690f9a9872d1c08ae96930ec549d7@akka://flink/user/rpc/jobmanager_3 for job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,803 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - JobManager successfully registered at ResourceManager, leader id: 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,804 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{b1b99749d1a3af19da63d2f9a43c886c}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,806 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,815 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request fc0eafaa46685a35a94156ecbe8e8a91 for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,826 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,828 
INFO&nbsp; org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - 
Add job 74824018367ce6f9d3f1be019242b46a for job leader monitoring. 
09:51:35,832 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Resolved 
JobManager address, beginning registration 09:51:35,838 WARN&nbsp; 
org.apache.flink.runtime.taskmanager.TaskManagerLocation&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
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&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Establish JobManager connection for job 74824018367ce6f9d3f1be019242b46a. 
09:51:35,852 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,874 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{12eec08ff74ff08a9a99b2131cbbd24a}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,875 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,876 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{9b345ff97fcfc6caa93b0f00142d8443}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,876 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request 239128e310ebcdf2f28ce17cf68b083b for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,877 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for 239128e310ebcdf2f28ce17cf68b083b. 09:51:35,877 
INFO&nbsp; org.apache.flink.runtime.resourcemanager.StandaloneResourceManager 
[] - Request slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,879 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,879 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request cf7dbb0d75022a259dab719bc343ef6b for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,879 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{2eaff8f1fa6d539bfb124a2aaa46afd6}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,880 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,880 
INFO&nbsp; org.apache.flink.runtime.resourcemanager.StandaloneResourceManager 
[] - Request slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,880 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,880 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{cfbadfffb678c2c24318aa7e023d8a44}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,884 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{765c41ef9466d9fe7ca028a9cb0717b6}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,885 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{5f4da62bbddcbb5fcdc3d851c4417afd}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,885 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,886 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,886 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Requesting new slot [SlotRequestId{f6559f3d11fad8e5d5ffc97820f5f889}] and 
profile ResourceProfile{UNKNOWN} from resource manager. 09:51:35,887 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
e4c7fd9f86fb37692505c272f3462065. 09:51:35,888 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,889 INFO&nbsp; 
org.apache.flink.runtime.resourcemanager.StandaloneResourceManager [] - Request 
slot with profile ResourceProfile{UNKNOWN} for job 
74824018367ce6f9d3f1be019242b46a with allocation id 
c53d0733a29a09a249599c2b50258aa3. 09:51:35,892 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,892 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. 
Ignoring. 09:51:35,893 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request 32c26f96585d3164f21d9e5fc0f2734b for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,894 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for 32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,894 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,895 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,895 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. 
Ignoring. 09:51:35,895 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request fde097f03a36bb4a49b4dcc1ffaa85dc for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,896 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. 
Ignoring. 09:51:35,896 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,896 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,897 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,897 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. 
Ignoring. 09:51:35,897 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b]. 
Ignoring. 09:51:35,897 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request 24df0325dc9d490f3b82ee07dc11e3f0 for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,898 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. 
Ignoring. 09:51:35,898 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for 24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,898 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,899 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,899 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request e4c7fd9f86fb37692505c272f3462065 for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,899 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. 
Ignoring. 09:51:35,899 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for e4c7fd9f86fb37692505c272f3462065. 09:51:35,899 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,900 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b]. 
Ignoring. 09:51:35,900 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. 
Ignoring. 09:51:35,901 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc]. 
Ignoring. 09:51:35,901 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b]. 
Ignoring. 09:51:35,901 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fc0eafaa46685a35a94156ecbe8e8a91]. 
Ignoring. 09:51:35,902 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [239128e310ebcdf2f28ce17cf68b083b]. 
Ignoring. 09:51:35,902 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [24df0325dc9d490f3b82ee07dc11e3f0]. 
Ignoring. 09:51:35,902 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,902 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,902 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. 
Ignoring. 09:51:35,903 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,903 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc]. 
Ignoring. 09:51:35,903 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Receive slot request c53d0733a29a09a249599c2b50258aa3 for job 
74824018367ce6f9d3f1be019242b46a from resource manager with leader id 
865828ddf3546a507f0868c7b5bf4c3a. 09:51:35,903 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Allocated slot for c53d0733a29a09a249599c2b50258aa3. 09:51:35,903 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Offer reserved slots to the leader of job 
74824018367ce6f9d3f1be019242b46a. 09:51:35,904 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,905 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,905 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,905 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,905 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from SCHEDULED to DEPLOYING. 09:51:35,906 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,906 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,906 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,906 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - 
Activate slot fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,907 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
e4c7fd9f86fb37692505c272f3462065. 09:51:35,908 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:35,909 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:35,918 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:35,918 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from SCHEDULED to DEPLOYING. 
09:51:35,918 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from SCHEDULED to DEPLOYING. 
09:51:35,922 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from SCHEDULED to DEPLOYING. 
09:51:35,923 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from SCHEDULED to DEPLOYING. 
09:51:35,925 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from SCHEDULED to DEPLOYING. 
09:51:35,926 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from SCHEDULED to DEPLOYING. 
09:51:35,928 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from SCHEDULED to DEPLOYING. 
09:51:35,929 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from SCHEDULED to DEPLOYING. 
09:51:35,930 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Deploying Filter -&amp;gt; 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&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [24df0325dc9d490f3b82ee07dc11e3f0]. 
Ignoring. 09:51:35,930 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [32c26f96585d3164f21d9e5fc0f2734b]. 
Ignoring. 09:51:35,930 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [e4c7fd9f86fb37692505c272f3462065]. 
Ignoring. 09:51:35,930 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [cf7dbb0d75022a259dab719bc343ef6b]. 
Ignoring. 09:51:35,930 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received repeated offer for slot [fde097f03a36bb4a49b4dcc1ffaa85dc]. 
Ignoring. 09:51:35,974 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Source: Collection Source (1/1). 09:51:35,976 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from CREATED to DEPLOYING. 09:51:35,980 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
c53d0733a29a09a249599c2b50258aa3. 09:51:35,986 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Source: Collection Source (1/1) 
(cf27fdfdd94b8d309f818f6fabe4a918) [DEPLOYING]. 09:51:35,989 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Source: Collection Source (1/1) 
(cf27fdfdd94b8d309f818f6fabe4a918) [DEPLOYING]. 09:51:36,007 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (1/8). 
09:51:36,007 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
e4c7fd9f86fb37692505c272f3462065. 09:51:36,008 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from CREATED to DEPLOYING. 
09:51:36,013 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) [DEPLOYING]. 09:51:36,015 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(1/8) (63ec26a28f8b355690403c16c5c01248) [DEPLOYING]. 09:51:36,022 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (2/8). 
09:51:36,024 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:36,034 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from CREATED to DEPLOYING. 
09:51:36,034 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) [DEPLOYING]. 09:51:36,036 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(2/8) (8435324290011c003b956e0ca887f57f) [DEPLOYING]. 09:51:36,039 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (3/8). 
09:51:36,040 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:36,043 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from CREATED to DEPLOYING. 
09:51:36,044 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,045 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (4/8). 
09:51:36,045 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(3/8) (202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,046 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from CREATED to DEPLOYING. 
09:51:36,047 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) [DEPLOYING]. 09:51:36,048 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(4/8) (87aa40a14210b0bf5fc3185afb07f32a) [DEPLOYING]. 09:51:36,049 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:36,050 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (5/8). 
09:51:36,056 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:36,060 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (6/8). 
09:51:36,060 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
239128e310ebcdf2f28ce17cf68b083b. 09:51:36,064 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from DEPLOYING to RUNNING. 
09:51:36,065 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from DEPLOYING to RUNNING. 
09:51:36,066 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from DEPLOYING to RUNNING. 
09:51:36,066 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from DEPLOYING to RUNNING. 
09:51:36,067 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from DEPLOYING to RUNNING. 
09:51:36,067 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from DEPLOYING to RUNNING. 
09:51:36,068 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from DEPLOYING to RUNNING. 
09:51:36,068 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from DEPLOYING to RUNNING. 09:51:36,068 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from DEPLOYING to RUNNING. 
09:51:36,060 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from CREATED to DEPLOYING. 
09:51:36,069 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from DEPLOYING to RUNNING. 09:51:36,069 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) [DEPLOYING]. 09:51:36,070 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from CREATED to DEPLOYING. 
09:51:36,071 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) [DEPLOYING]. 09:51:36,071 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) [DEPLOYING]. 09:51:36,072 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (7/8). 
09:51:36,073 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(6/8) (546ab10ef414b66815d8f9f67ca43854) [DEPLOYING]. 09:51:36,074 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from DEPLOYING to RUNNING. 
09:51:36,074 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from CREATED to DEPLOYING. 
09:51:36,074 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) [DEPLOYING]. 09:51:36,075 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from DEPLOYING to RUNNING. 
09:51:36,077 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from DEPLOYING to RUNNING. 
09:51:36,077 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fc0eafaa46685a35a94156ecbe8e8a91. 09:51:36,077 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from DEPLOYING to RUNNING. 
09:51:36,079 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(7/8) (8700548cd2d3904f0d3397c01e1765ef) [DEPLOYING]. 09:51:36,080 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Received task Filter -&amp;gt; Sink: Print to Std. Out (8/8). 
09:51:36,081 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
c53d0733a29a09a249599c2b50258aa3. 09:51:36,081 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
24df0325dc9d490f3b82ee07dc11e3f0. 09:51:36,081 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
32c26f96585d3164f21d9e5fc0f2734b. 09:51:36,081 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
e4c7fd9f86fb37692505c272f3462065. 09:51:36,081 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
cf7dbb0d75022a259dab719bc343ef6b. 09:51:36,081 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 
fde097f03a36bb4a49b4dcc1ffaa85dc. 09:51:36,082 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from DEPLOYING to RUNNING. 
09:51:36,083 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from DEPLOYING to RUNNING. 
09:51:36,088 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from CREATED to DEPLOYING. 
09:51:36,089 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Loading JAR files for task Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) [DEPLOYING]. 09:51:36,090 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Registering task at network: Filter -&amp;gt; Sink: Print to Std. Out 
(8/8) (36d5274707b482655bb989df2d910cc9) [DEPLOYING]. 09:51:36,093 INFO&nbsp; 
org.apache.flink.streaming.runtime.tasks.StreamTask&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - 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&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from DEPLOYING to RUNNING. 
09:51:36,094 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from DEPLOYING to RUNNING. 
8&amp;gt; Wilma: age 35 7&amp;gt; Fred: age 35 09:51:36,234 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from RUNNING to FINISHED. 09:51:36,234 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Source: Collection Source (1/1) 
(cf27fdfdd94b8d309f818f6fabe4a918). 09:51:36,238 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Source: Collection Source (1/1) 
cf27fdfdd94b8d309f818f6fabe4a918. 09:51:36,239 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from RUNNING to FINISHED. 
09:51:36,239 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from RUNNING to FINISHED. 
09:51:36,239 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from RUNNING to FINISHED. 
09:51:36,239 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854). 09:51:36,239 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from RUNNING to FINISHED. 
09:51:36,240 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a). 09:51:36,240 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3). 09:51:36,241 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from RUNNING to FINISHED. 
09:51:36,242 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9). 09:51:36,242 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from RUNNING to FINISHED. 
09:51:36,242 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122). 09:51:36,242 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from RUNNING to FINISHED. 
09:51:36,243 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f). 09:51:36,241 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248). 09:51:36,243 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from RUNNING to FINISHED. 
09:51:36,244 INFO&nbsp; 
org.apache.flink.runtime.taskmanager.Task&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Freeing task resources for Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef). 09:51:36,260 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
546ab10ef414b66815d8f9f67ca43854. 09:51:36,261 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
87aa40a14210b0bf5fc3185afb07f32a. 09:51:36,262 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Source: Collection Source (1/1) (cf27fdfdd94b8d309f818f6fabe4a918) 
switched from RUNNING to FINISHED. 09:51:36,263 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
c43b45ca5ea59c6a262cc4b95fe318f3. 09:51:36,263 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
36d5274707b482655bb989df2d910cc9. 09:51:36,264 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
202d4a956de7c80d8d4ed7eb6d85f122. 09:51:36,265 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
8435324290011c003b956e0ca887f57f. 09:51:36,265 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (6/8) 
(546ab10ef414b66815d8f9f67ca43854) switched from RUNNING to FINISHED. 
09:51:36,266 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
63ec26a28f8b355690403c16c5c01248. 09:51:36,266 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Un-registering task and sending final execution state FINISHED to 
JobManager for task Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
8700548cd2d3904f0d3397c01e1765ef. 09:51:36,269 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (4/8) 
(87aa40a14210b0bf5fc3185afb07f32a) switched from RUNNING to FINISHED. 
09:51:36,270 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (5/8) 
(c43b45ca5ea59c6a262cc4b95fe318f3) switched from RUNNING to FINISHED. 
09:51:36,271 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (8/8) 
(36d5274707b482655bb989df2d910cc9) switched from RUNNING to FINISHED. 
09:51:36,272 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (3/8) 
(202d4a956de7c80d8d4ed7eb6d85f122) switched from RUNNING to FINISHED. 
09:51:36,273 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (2/8) 
(8435324290011c003b956e0ca887f57f) switched from RUNNING to FINISHED. 
09:51:36,274 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (1/8) 
(63ec26a28f8b355690403c16c5c01248) switched from RUNNING to FINISHED. 
09:51:36,275 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Filter -&amp;gt; Sink: Print to Std. Out (7/8) 
(8700548cd2d3904f0d3397c01e1765ef) switched from RUNNING to FINISHED. 
09:51:36,275 INFO&nbsp; 
org.apache.flink.runtime.executiongraph.ExecutionGraph&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Job Flink Streaming Job (74824018367ce6f9d3f1be019242b46a) switched from 
state RUNNING to FINISHED. 09:51:36,275 INFO&nbsp; 
org.apache.flink.runtime.checkpoint.CheckpointCoordinator&nbsp;&nbsp;&nbsp; [] 
- Stopping checkpoint coordinator for job 74824018367ce6f9d3f1be019242b46a. 
09:51:36,279 INFO&nbsp; 
org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore [] - 
Shutting down 09:51:36,298 INFO&nbsp; 
org.apache.flink.runtime.minicluster.MiniCluster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Shutting down Flink Mini Cluster 09:51:36,299 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Shutting down rest endpoint. 09:51:36,299 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Stopping TaskExecutor akka://flink/user/rpc/taskmanager_0. 09:51:36,299 
INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Close ResourceManager connection c853dc79e27b12d44efc839c049c59ce. 
09:51:36,299 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.StandaloneDispatcher&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Job 74824018367ce6f9d3f1be019242b46a reached globally terminal state 
FINISHED. 09:51:36,302 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Close JobManager connection for job 74824018367ce6f9d3f1be019242b46a. 
09:51:36,305 INFO&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
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&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Stopping the JobMaster for job Flink Streaming 
Job(74824018367ce6f9d3f1be019242b46a). 09:51:36,316 INFO&nbsp; 
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&nbsp; 
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&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Suspending SlotPool. 09:51:36,325 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.JobMaster&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Close ResourceManager connection c853dc79e27b12d44efc839c049c59ce: 
JobManager is shutting down.. 09:51:36,325 INFO&nbsp; 
org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl&nbsp;&nbsp;&nbsp;&nbsp;
 [] - Stopping SlotPool. 09:51:36,328 INFO&nbsp; 
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&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Removing cache directory C:\Users\tanghong\AppData\Local\Temp\flink-web-ui 
09:51:36,372 INFO&nbsp; 
org.apache.flink.runtime.taskexecutor.TaskExecutor&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;
 [] - JobManager for job 74824018367ce6f9d3f1be019242b46a with leader id 
8da690f9a9872d1c08ae96930ec549d7 lost leadership. 09:51:36,376 INFO&nbsp; 
org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint&nbsp;&nbsp; [] - 
Shut down complete.

??????no print

回复