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 {

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

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

        DataStream<Person&gt; adults = flintstones.filter(new FilterFunction<Person&gt;() {
            @Override
            public boolean filter(Person person) throws Exception {
                return person.age &gt;= 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&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  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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248) [DEPLOYING]. 09:51:36,022 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Received task Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f) [DEPLOYING]. 09:51:36,039 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Received task Filter -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,045 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Received task Filter -&gt; Sink: Print to Std. Out (4/8). 09:51:36,045 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Registering task at network: Filter -&gt; Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122) [DEPLOYING]. 09:51:36,046 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3) [DEPLOYING]. 09:51:36,070 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (7/8). 09:51:36,073 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Registering task at network: Filter -&gt; Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854) [DEPLOYING]. 09:51:36,074 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (7/8) (8700548cd2d3904f0d3397c01e1765ef) [DEPLOYING]. 09:51:36,080 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor           [] - Received task Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9) switched from DEPLOYING to RUNNING. 8&gt; Wilma: age 35 7&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (6/8) (546ab10ef414b66815d8f9f67ca43854). 09:51:36,239 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; Sink: Print to Std. Out (4/8) (87aa40a14210b0bf5fc3185afb07f32a). 09:51:36,240 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Freeing task resources for Filter -&gt; Sink: Print to Std. Out (5/8) (c43b45ca5ea59c6a262cc4b95fe318f3). 09:51:36,241 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; Sink: Print to Std. Out (8/8) (36d5274707b482655bb989df2d910cc9). 09:51:36,242 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; Sink: Print to Std. Out (3/8) (202d4a956de7c80d8d4ed7eb6d85f122). 09:51:36,242 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; Sink: Print to Std. Out (2/8) (8435324290011c003b956e0ca887f57f). 09:51:36,241 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Freeing task resources for Filter -&gt; Sink: Print to Std. Out (1/8) (63ec26a28f8b355690403c16c5c01248). 09:51:36,243 INFO  org.apache.flink.runtime.taskmanager.Task                    [] - Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (2/8) 8435324290011c003b956e0ca887f57f. 09:51:36,265 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&gt; 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 -&gt; Sink: Print to Std. Out (7/8) 8700548cd2d3904f0d3397c01e1765ef. 09:51:36,269 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Filter -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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 -&gt; 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.

[jacky-cui]

你这个是在本地执行的吗，我的flink版本是1.10版本，本地执行提交是可以打印输出结果的，结果如下：
6&gt; Wilma: age 35
5&gt; Fred: age 35



你用的flink是什么版本


------------------&nbsp;原始邮件&nbsp;------------------
发件人:                                                                                                                        "user-zh"                                                                                    <[hidden email]&gt;;
发送时间:&nbsp;2020年8月11日(星期二) 中午11:30
收件人:&nbsp;"user-zh"<[hidden email]&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.