flink log 1

/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/bin/java -javaagent:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar=60475:/Applications/IntelliJ IDEA.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/deploy.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/jfxrt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/javaws.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/jfxswt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/plugin.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/ant-javafx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/javafx-mx.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/packager.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/jdk1.8.0_221.jdk/Contents/Home/lib/tools.jar:/Users/xinwei/Documents/weixin/github/examples-scala/target/classes:/Users/xinwei/.m2/repository/org/apache/flink/flink-scala_2.12/1.7.1/flink-scala_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-core/1.7.1/flink-core-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-annotations/1.7.1/flink-annotations-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-metrics-core/1.7.1/flink-metrics-core-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/xinwei/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/xinwei/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/xinwei/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/xinwei/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/xinwei/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/Users/xinwei/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-java/1.7.1/flink-java-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-shaded-asm/5.0.4-5.0/flink-shaded-asm-5.0.4-5.0.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-shaded-asm-6/6.2.1-5.0/flink-shaded-asm-6-6.2.1-5.0.jar:/Users/xinwei/.m2/repository/org/scala-lang/scala-reflect/2.12.7/scala-reflect-2.12.7.jar:/Users/xinwei/.m2/repository/org/scala-lang/scala-compiler/2.12.7/scala-compiler-2.12.7.jar:/Users/xinwei/.m2/repository/org/scala-lang/modules/scala-xml_2.12/1.0.6/scala-xml_2.12-1.0.6.jar:/Users/xinwei/.m2/repository/org/slf4j/slf4j-api/1.7.15/slf4j-api-1.7.15.jar:/Users/xinwei/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/xinwei/.m2/repository/org/apache/flink/force-shading/1.7.1/force-shading-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-streaming-scala_2.12/1.7.1/flink-streaming-scala_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-streaming-java_2.12/1.7.1/flink-streaming-java_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/scala-lang/scala-library/2.12.8/scala-library-2.12.8.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-runtime-web_2.12/1.7.1/flink-runtime-web_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-runtime_2.12/1.7.1/flink-runtime_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-hadoop-fs/1.7.1/flink-hadoop-fs-1.7.1.jar:/Users/xinwei/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/xinwei/.m2/repository/commons-cli/commons-cli/1.3.1/commons-cli-1.3.1.jar:/Users/xinwei/.m2/repository/com/typesafe/akka/akka-actor_2.12/2.4.20/akka-actor_2.12-2.4.20.jar:/Users/xinwei/.m2/repository/com/typesafe/config/1.3.0/config-1.3.0.jar:/Users/xinwei/.m2/repository/org/scala-lang/modules/scala-java8-compat_2.12/0.8.0/scala-java8-compat_2.12-0.8.0.jar:/Users/xinwei/.m2/repository/com/typesafe/akka/akka-stream_2.12/2.4.20/akka-stream_2.12-2.4.20.jar:/Users/xinwei/.m2/repository/org/reactivestreams/reactive-streams/1.0.0/reactive-streams-1.0.0.jar:/Users/xinwei/.m2/repository/com/typesafe/ssl-config-core_2.12/0.2.1/ssl-config-core_2.12-0.2.1.jar:/Users/xinwei/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.12/1.0.4/scala-parser-combinators_2.12-1.0.4.jar:/Users/xinwei/.m2/repository/com/typesafe/akka/akka-protobuf_2.12/2.4.20/akka-protobuf_2.12-2.4.20.jar:/Users/xinwei/.m2/repository/com/typesafe/akka/akka-slf4j_2.12/2.4.20/akka-slf4j_2.12-2.4.20.jar:/Users/xinwei/.m2/repository/org/clapper/grizzled-slf4j_2.12/1.3.2/grizzled-slf4j_2.12-1.3.2.jar:/Users/xinwei/.m2/repository/com/github/scopt/scopt_2.12/3.5.0/scopt_2.12-3.5.0.jar:/Users/xinwei/.m2/repository/org/xerial/snappy/snappy-java/1.1.4/snappy-java-1.1.4.jar:/Users/xinwei/.m2/repository/com/twitter/chill_2.12/0.7.6/chill_2.12-0.7.6.jar:/Users/xinwei/.m2/repository/com/twitter/chill-java/0.7.6/chill-java-0.7.6.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-clients_2.12/1.7.1/flink-clients_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-optimizer_2.12/1.7.1/flink-optimizer_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.24.Final-5.0/flink-shaded-netty-4.1.24.Final-5.0.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-shaded-guava/18.0-5.0/flink-shaded-guava-18.0-5.0.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-shaded-jackson/2.7.9-5.0/flink-shaded-jackson-2.7.9-5.0.jar:/Users/xinwei/.m2/repository/org/javassist/javassist/3.19.0-GA/javassist-3.19.0-GA.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-queryable-state-runtime_2.12/1.7.1/flink-queryable-state-runtime_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/flink/flink-queryable-state-client-java_2.12/1.7.1/flink-queryable-state-client-java_2.12-1.7.1.jar:/Users/xinwei/.m2/repository/org/apache/derby/derby/10.13.1.1/derby-10.13.1.1.jar:/Users/xinwei/.m2/repository/org/slf4j/slf4j-log4j12/1.7.25/slf4j-log4j12-1.7.25.jar:/Users/xinwei/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar io.github.streamingwithflink.chapter6.CoProcessFunctionTimers
22:43:51,368 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - class io.github.streamingwithflink.util.SensorReading does not contain a setter for field id
22:43:51,369 INFO  org.apache.flink.api.java.typeutils.TypeExtractor             - Class class io.github.streamingwithflink.util.SensorReading cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance.
22:43:51,480 INFO  org.apache.flink.streaming.api.environment.LocalStreamEnvironment  - Running job on local embedded Flink mini cluster
22:43:51,486 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting Flink Mini Cluster
22:43:51,532 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting Metrics Registry
22:43:51,578 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl           - No metrics reporter configured, no metrics will be exposed/reported.
22:43:51,631 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting RPC Service(s)
22:43:51,965 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
22:43:51,980 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Trying to start actor system at :0
22:43:52,017 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
22:43:52,065 INFO  akka.remote.Remoting                                          - Starting remoting
22:43:52,190 INFO  akka.remote.Remoting                                          - Remoting started; listening on addresses :[akka.tcp://flink-metrics@192.168.1.26:60479]
22:43:52,203 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Actor system started at akka.tcp://flink-metrics@192.168.1.26:60479
22:43:52,205 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting high-availability services
22:43:52,214 INFO  org.apache.flink.runtime.blob.BlobServer                      - Created BLOB server storage directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/blobStore-b6e07df9-106e-47fa-9d35-e0feb1a65051
22:43:52,217 INFO  org.apache.flink.runtime.blob.BlobServer                      - Started BLOB server at 0.0.0.0:60480 - max concurrent requests: 50 - max backlog: 1000
22:43:52,218 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting ResourceManger
22:43:52,229 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe .
22:43:52,241 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@85e6769 @ akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe
22:43:52,243 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - ResourceManager akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe was granted leadership with fencing token b227cdcde457c2ee63cf15b873e34205
22:43:52,243 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Starting the SlotManager.
22:43:52,245 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Received confirmation of leadership for leader akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe , session=63cf15b8-73e3-4205-b227-cdcde457c2ee
22:43:52,247 INFO  org.apache.flink.runtime.blob.PermanentBlobCache              - Created BLOB cache storage directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/blobStore-070d5f25-af83-4378-9c1d-0c74d3cead1f
22:43:52,248 INFO  org.apache.flink.runtime.blob.TransientBlobCache              - Created BLOB cache storage directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/blobStore-ad7c7ca6-c2a3-4720-80a9-ac14dec42699
22:43:52,248 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting 1 TaskManger(s)
22:43:52,252 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerRunner       - Starting TaskManager with ResourceID: eed18069-09cc-4f6e-8600-33d8618c01b8
22:43:52,308 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices     - Temporary file directory '/var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T': total 931 GB, usable 734 GB (78.84% usable)
22:43:52,656 INFO  org.apache.flink.runtime.io.network.buffer.NetworkBufferPool  - Allocated 809 MB for network buffer pool (number of memory segments: 25891, bytes per segment: 32768).
22:43:52,664 INFO  org.apache.flink.runtime.io.network.NetworkEnvironment        - Starting the network environment and its components.
22:43:52,763 INFO  org.apache.flink.queryablestate.server.KvStateServerImpl      - Started Queryable State Server @ /127.0.0.1:9067.
22:43:52,769 INFO  org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl  - Started Queryable State Proxy Server @ /127.0.0.1:9069.
22:43:52,771 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerServices     - Limiting managed memory to 0.7 of the currently free heap space (5089 MB), memory will be allocated lazily.
22:43:52,774 INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager          - I/O manager uses directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/flink-io-192b3f88-2610-45ea-96d8-119774498ca3 for spill files.
22:43:52,781 INFO  org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration  - Messages have a max timeout of 10000 ms
22:43:52,786 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/taskmanager_0 .
22:43:52,792 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Start job leader service.
22:43:52,793 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Connecting to ResourceManager akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe(b227cdcde457c2ee63cf15b873e34205).
22:43:52,793 INFO  org.apache.flink.runtime.filecache.FileCache                  - User file cache uses directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/flink-dist-cache-ec01967c-5bbd-46d9-8c3c-223f713f2948
22:43:52,794 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting dispatcher rest endpoint.
22:43:52,803 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Resolved ResourceManager address, beginning registration
22:43:52,803 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Registration at ResourceManager attempt 1 (timeout=100ms)
22:43:52,807 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Registering TaskManager with ResourceID eed18069-09cc-4f6e-8600-33d8618c01b8 (akka://flink/user/taskmanager_0) at ResourceManager
22:43:52,808 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Successful registration at resource manager akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe under registration id 63f0709db405d72d7643b0d9d3734b52.
22:43:52,823 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint    - Starting rest endpoint.
22:43:52,964 WARN  org.apache.flink.runtime.webmonitor.WebMonitorUtils           - Log file environment variable 'log.file' is not set.
22:43:52,964 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 'Key: 'web.log.path' , default: null (deprecated keys: [jobmanager.web.log.path])'.
22:43:52,985 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint    - Rest endpoint listening at localhost:60481
22:43:52,985 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Proposing leadership to contender org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint@40226788 @ http://localhost:60481
22:43:52,986 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint    - Web frontend listening at http://localhost:60481.
22:43:52,986 INFO  org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint    - http://localhost:60481 was granted leadership with leaderSessionID=8f76687d-ff41-45d2-ae0b-85049925ba17
22:43:52,986 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Starting job dispatcher(s) for JobManger
22:43:52,986 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Received confirmation of leadership for leader http://localhost:60481 , session=8f76687d-ff41-45d2-ae0b-85049925ba17
22:43:52,992 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatchere5c6f397-af7e-4254-ad6f-f7cf93e02870 .
22:43:53,000 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@6ef7623 @ akka://flink/user/dispatchere5c6f397-af7e-4254-ad6f-f7cf93e02870
22:43:53,000 INFO  org.apache.flink.runtime.minicluster.MiniCluster              - Flink Mini Cluster started successfully
22:43:53,000 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Dispatcher akka://flink/user/dispatchere5c6f397-af7e-4254-ad6f-f7cf93e02870 was granted leadership with fencing token b8c1d779-0ccf-4936-8bce-c13cbda5657c
22:43:53,001 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Recovering all persisted jobs.
22:43:53,002 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Received confirmation of leadership for leader akka://flink/user/dispatchere5c6f397-af7e-4254-ad6f-f7cf93e02870 , session=b8c1d779-0ccf-4936-8bce-c13cbda5657c
22:43:53,008 INFO  org.apache.flink.runtime.dispatcher.StandaloneDispatcher      - Submitting job c3d9510692f897597e742ce0e4903adf (Monitor sensor temperatures.).
22:43:53,020 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_1 .
22:43:53,027 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Initializing job Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf).
22:43:53,031 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Using restart strategy NoRestartStrategy for Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf).
22:43:53,035 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/61346e5c-b1c9-442d-8520-afb1c5feb118 .
22:43:53,048 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job recovers via failover strategy: full graph restart
22:43:53,070 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Running initialization on master for job Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf).
22:43:53,071 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully ran initialization on master in 0 ms.
22:43:53,086 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)
22:43:53,093 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@30528e7c @ akka://flink/user/jobmanager_1
22:43:53,094 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManager runner for job Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf) was granted leadership with session id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5 at akka://flink/user/jobmanager_1.
22:43:53,095 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Starting execution of job Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf)
22:43:53,095 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job Monitor sensor temperatures. (c3d9510692f897597e742ce0e4903adf) switched from state CREATED to RUNNING.
22:43:53,097 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from CREATED to SCHEDULED.
22:43:53,099 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) switched from CREATED to SCHEDULED.
22:43:53,099 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) switched from CREATED to SCHEDULED.
22:43:53,099 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) switched from CREATED to SCHEDULED.
22:43:53,100 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) switched from CREATED to SCHEDULED.
22:43:53,101 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) switched from CREATED to SCHEDULED.
22:43:53,101 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) switched from CREATED to SCHEDULED.
22:43:53,101 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) switched from CREATED to SCHEDULED.
22:43:53,101 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) switched from CREATED to SCHEDULED.
22:43:53,101 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) switched from CREATED to SCHEDULED.
22:43:53,102 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) switched from CREATED to SCHEDULED.
22:43:53,103 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{7a14090476e8d4db62ddccaeb7895d30}]
22:43:53,104 INFO  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Received confirmation of leadership for leader akka://flink/user/jobmanager_1 , session=ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5
22:43:53,104 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Connecting to ResourceManager akka://flink/user/resourcemanager_48e1826a-4a3d-4b8b-9e51-1bd1de37b9fe(b227cdcde457c2ee63cf15b873e34205)
22:43:53,105 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Resolved ResourceManager address, beginning registration
22:43:53,105 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Registration at ResourceManager attempt 1 (timeout=100ms)
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{792c384f4263e5044356fc58391b1ca0}]
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{92a9b5106268e2232b5c213c4c361a90}]
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{07714d9410200dcb58f7ab5f5a1f700e}]
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{317a057fd608e99f1caa82546d4f98a3}]
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{8b76e4daded2add481bf42ada872ba8f}]
22:43:53,106 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Registering job manager a7f9ba4dc07b0ce5ec30b2cc8fa749e8@akka://flink/user/jobmanager_1 for job c3d9510692f897597e742ce0e4903adf.
22:43:53,106 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{4d85a091ed1d07b494825a88dbe7c944}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{f4d9d2f50a22281be7b136003e1177e9}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{c366c438412421fdc2f27bb400e2fbd8}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{22c9c2f2deb798de0c69594ba2529f20}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{3bf70ca2b445bf586fb5dfef209c2303}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{036b4626d15fa5997cf470caae7cf279}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{6fe38442fdbcd7e27a8e39921ed424ac}]
22:43:53,107 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{8fdde41fffff4d096cecc0f802504f7a}]
22:43:53,108 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{b864b3ca6696a4f8676283365d1529f6}]
22:43:53,108 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{15e62ab1195cb72c91da9e89ed82fee8}]
22:43:53,109 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Registered job manager a7f9ba4dc07b0ce5ec30b2cc8fa749e8@akka://flink/user/jobmanager_1 for job c3d9510692f897597e742ce0e4903adf.
22:43:53,110 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - JobManager successfully registered at ResourceManager, leader id: b227cdcde457c2ee63cf15b873e34205.
22:43:53,111 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{317a057fd608e99f1caa82546d4f98a3}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,111 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{7e1ab22873c571366f218fb53889ef48}.
22:43:53,112 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{22c9c2f2deb798de0c69594ba2529f20}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,112 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{8b76e4daded2add481bf42ada872ba8f}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,112 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{7a14090476e8d4db62ddccaeb7895d30}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,112 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{7e1ab22873c571366f218fb53889ef48} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,112 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{8fdde41fffff4d096cecc0f802504f7a}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,112 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{3bf70ca2b445bf586fb5dfef209c2303}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{cc3eb43cd0479641d82d13ce3799d7ec}.
22:43:53,113 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{036b4626d15fa5997cf470caae7cf279}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{7e1ab22873c571366f218fb53889ef48}.
22:43:53,113 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,113 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{792c384f4263e5044356fc58391b1ca0}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{803bbde908bc053dd7d8fe7af33304c6}.
22:43:53,113 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{92a9b5106268e2232b5c213c4c361a90}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{ca68aee9ec55c669fc31e818c175b712}.
22:43:53,113 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{4d85a091ed1d07b494825a88dbe7c944}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{07714d9410200dcb58f7ab5f5a1f700e}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,113 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{570d34907a87687bce689a26ec491445}.
22:43:53,114 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{b864b3ca6696a4f8676283365d1529f6}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{cc3eb43cd0479641d82d13ce3799d7ec} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,114 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{574c64e6b37966f5229b1907416a6686}.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{cc3eb43cd0479641d82d13ce3799d7ec}.
22:43:53,114 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{c366c438412421fdc2f27bb400e2fbd8}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,114 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{8e7b681b025021bcc87e06044c4b705c}.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{803bbde908bc053dd7d8fe7af33304c6} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,114 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{6fe38442fdbcd7e27a8e39921ed424ac}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{803bbde908bc053dd7d8fe7af33304c6}.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,114 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{f4d9d2f50a22281be7b136003e1177e9}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,114 WARN  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Error notifying leader listener about new leader
java.lang.IllegalStateException: The RPC connection is already closed
	at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
	at org.apache.flink.runtime.registration.RegisteredRpcConnection.start(RegisteredRpcConnection.java:91)
	at org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener.notifyLeaderAddress(JobLeaderService.java:327)
	at org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService$NotifyOfLeaderCall.run(EmbeddedLeaderService.java:430)
	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
22:43:53,114 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting new slot [SlotRequestId{15e62ab1195cb72c91da9e89ed82fee8}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
22:43:53,114 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{f6eed4179c2139ead6ab9d95bdd5c7a7}.
22:43:53,114 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{ca68aee9ec55c669fc31e818c175b712} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{ca68aee9ec55c669fc31e818c175b712}.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,116 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{e4cf9e715c2167e24aedd5e4dd146bd4}.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{570d34907a87687bce689a26ec491445} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{570d34907a87687bce689a26ec491445}.
22:43:53,116 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{eb32c8827c911ea5cb2d618aee240b4c}.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,116 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,117 WARN  org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService  - Error notifying leader listener about new leader
java.lang.IllegalStateException: The RPC connection is already closed
	at org.apache.flink.util.Preconditions.checkState(Preconditions.java:195)
	at org.apache.flink.runtime.registration.RegisteredRpcConnection.start(RegisteredRpcConnection.java:91)
	at org.apache.flink.runtime.taskexecutor.JobLeaderService$JobManagerLeaderListener.notifyLeaderAddress(JobLeaderService.java:327)
	at org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService$NotifyOfLeaderCall.run(EmbeddedLeaderService.java:430)
	at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39)
	at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415)
	at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
	at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
	at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
	at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157)
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,117 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{2dbd29d6cd7f9063bd079a9e0dddac2d}.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{574c64e6b37966f5229b1907416a6686} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{574c64e6b37966f5229b1907416a6686}.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{8e7b681b025021bcc87e06044c4b705c} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,117 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{d9cefccf4be0e855b9a999ebc7b6ac3b}.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{8e7b681b025021bcc87e06044c4b705c}.
22:43:53,117 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{f6eed4179c2139ead6ab9d95bdd5c7a7} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{f6eed4179c2139ead6ab9d95bdd5c7a7}.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,118 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{c3c9117be5edcdc928aefe87938c4c18}.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{e4cf9e715c2167e24aedd5e4dd146bd4} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{e4cf9e715c2167e24aedd5e4dd146bd4}.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{eb32c8827c911ea5cb2d618aee240b4c} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,118 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{41b7caccca8f847edba72984d1c039b3}.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{eb32c8827c911ea5cb2d618aee240b4c}.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{2dbd29d6cd7f9063bd079a9e0dddac2d} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,118 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{2dbd29d6cd7f9063bd079a9e0dddac2d}.
22:43:53,119 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{62ce49ef69fd3e3134cbf200d86ecdfe}.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{d9cefccf4be0e855b9a999ebc7b6ac3b} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{d9cefccf4be0e855b9a999ebc7b6ac3b}.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{c3c9117be5edcdc928aefe87938c4c18} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{c3c9117be5edcdc928aefe87938c4c18}.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,119 INFO  org.apache.flink.runtime.resourcemanager.StandaloneResourceManager  - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job c3d9510692f897597e742ce0e4903adf with allocation id AllocationID{44de6beeb2e4717752a115653bdef1e3}.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{41b7caccca8f847edba72984d1c039b3} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,119 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{41b7caccca8f847edba72984d1c039b3}.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{62ce49ef69fd3e3134cbf200d86ecdfe} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{62ce49ef69fd3e3134cbf200d86ecdfe}.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,120 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Receive slot request AllocationID{44de6beeb2e4717752a115653bdef1e3} for job c3d9510692f897597e742ce0e4903adf from resource manager with leader id b227cdcde457c2ee63cf15b873e34205.
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Allocated slot for AllocationID{44de6beeb2e4717752a115653bdef1e3}.
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Add job c3d9510692f897597e742ce0e4903adf for job leader monitoring.
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Try to register at job manager akka://flink/user/jobmanager_1 with leader id ec30b2cc-8fa7-49e8-a7f9-ba4dc07b0ce5.
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Resolved JobManager address, beginning registration
22:43:53,121 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Registration at JobManager attempt 1 (timeout=100ms)
22:43:53,123 INFO  org.apache.flink.runtime.taskexecutor.JobLeaderService        - Successful registration at job manager akka://flink/user/jobmanager_1 for job c3d9510692f897597e742ce0e4903adf.
22:43:53,123 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Establish JobManager connection for job c3d9510692f897597e742ce0e4903adf.
22:43:53,125 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Offer reserved slots to the leader of job c3d9510692f897597e742ce0e4903adf.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{8e7b681b025021bcc87e06044c4b705c}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{570d34907a87687bce689a26ec491445}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{803bbde908bc053dd7d8fe7af33304c6}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{eb32c8827c911ea5cb2d618aee240b4c}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{c3c9117be5edcdc928aefe87938c4c18}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{cc3eb43cd0479641d82d13ce3799d7ec}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{ca68aee9ec55c669fc31e818c175b712}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{7e1ab22873c571366f218fb53889ef48}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{e4cf9e715c2167e24aedd5e4dd146bd4}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{574c64e6b37966f5229b1907416a6686}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{62ce49ef69fd3e3134cbf200d86ecdfe}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{41b7caccca8f847edba72984d1c039b3}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{44de6beeb2e4717752a115653bdef1e3}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{d9cefccf4be0e855b9a999ebc7b6ac3b}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{f6eed4179c2139ead6ab9d95bdd5c7a7}.
22:43:53,130 INFO  org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable      - Activate slot AllocationID{2dbd29d6cd7f9063bd079a9e0dddac2d}.
22:43:53,133 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) switched from SCHEDULED to DEPLOYING.
22:43:53,134 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (12/16) (attempt #0) to localhost
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) switched from SCHEDULED to DEPLOYING.
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (14/16) (attempt #0) to localhost
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) switched from SCHEDULED to DEPLOYING.
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (6/16) (attempt #0) to localhost
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) switched from SCHEDULED to DEPLOYING.
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (7/16) (attempt #0) to localhost
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) switched from SCHEDULED to DEPLOYING.
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (9/16) (attempt #0) to localhost
22:43:53,136 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) switched from SCHEDULED to DEPLOYING.
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (10/16) (attempt #0) to localhost
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) switched from SCHEDULED to DEPLOYING.
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (1/16) (attempt #0) to localhost
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) switched from SCHEDULED to DEPLOYING.
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (5/16) (attempt #0) to localhost
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) switched from SCHEDULED to DEPLOYING.
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (3/16) (attempt #0) to localhost
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) switched from SCHEDULED to DEPLOYING.
22:43:53,137 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (11/16) (attempt #0) to localhost
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) switched from SCHEDULED to DEPLOYING.
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (8/16) (attempt #0) to localhost
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) switched from SCHEDULED to DEPLOYING.
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (13/16) (attempt #0) to localhost
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) switched from SCHEDULED to DEPLOYING.
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (16/16) (attempt #0) to localhost
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) switched from SCHEDULED to DEPLOYING.
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (15/16) (attempt #0) to localhost
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) switched from SCHEDULED to DEPLOYING.
22:43:53,138 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (2/16) (attempt #0) to localhost
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) switched from SCHEDULED to DEPLOYING.
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source (4/16) (attempt #0) to localhost
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from SCHEDULED to DEPLOYING.
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Collection Source (1/1) (attempt #0) to localhost
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) switched from SCHEDULED to DEPLOYING.
22:43:53,139 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (16/16) (attempt #0) to localhost
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) switched from SCHEDULED to DEPLOYING.
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (15/16) (attempt #0) to localhost
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) switched from SCHEDULED to DEPLOYING.
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (14/16) (attempt #0) to localhost
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) switched from SCHEDULED to DEPLOYING.
22:43:53,141 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (13/16) (attempt #0) to localhost
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) switched from SCHEDULED to DEPLOYING.
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (12/16) (attempt #0) to localhost
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) switched from SCHEDULED to DEPLOYING.
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (11/16) (attempt #0) to localhost
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) switched from SCHEDULED to DEPLOYING.
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (10/16) (attempt #0) to localhost
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) switched from SCHEDULED to DEPLOYING.
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (9/16) (attempt #0) to localhost
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) switched from SCHEDULED to DEPLOYING.
22:43:53,142 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (8/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (7/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (6/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (5/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (4/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (3/16) (attempt #0) to localhost
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) switched from SCHEDULED to DEPLOYING.
22:43:53,143 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (2/16) (attempt #0) to localhost
22:43:53,144 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) switched from SCHEDULED to DEPLOYING.
22:43:53,144 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Co-Process -> Sink: Print to Std. Out (1/16) (attempt #0) to localhost
22:43:53,150 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (12/16).
22:43:53,151 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) switched from CREATED to DEPLOYING.
22:43:53,151 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) [DEPLOYING]
22:43:53,152 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (14/16).
22:43:53,153 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) switched from CREATED to DEPLOYING.
22:43:53,153 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) [DEPLOYING]
22:43:53,154 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) [DEPLOYING].
22:43:53,154 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) [DEPLOYING].
22:43:53,154 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (6/16).
22:43:53,155 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) switched from CREATED to DEPLOYING.
22:43:53,155 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) [DEPLOYING]
22:43:53,155 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) [DEPLOYING].
22:43:53,155 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) [DEPLOYING].
22:43:53,155 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) [DEPLOYING].
22:43:53,156 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) [DEPLOYING].
22:43:53,157 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (7/16).
22:43:53,157 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) switched from CREATED to DEPLOYING.
22:43:53,157 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) [DEPLOYING]
22:43:53,157 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) [DEPLOYING].
22:43:53,158 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) [DEPLOYING].
22:43:53,158 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (9/16).
22:43:53,159 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) switched from CREATED to DEPLOYING.
22:43:53,159 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) [DEPLOYING]
22:43:53,159 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) [DEPLOYING].
22:43:53,159 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) [DEPLOYING].
22:43:53,160 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (10/16).
22:43:53,160 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) switched from CREATED to DEPLOYING.
22:43:53,160 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) [DEPLOYING]
22:43:53,160 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) [DEPLOYING].
22:43:53,161 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) [DEPLOYING].
22:43:53,162 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (1/16).
22:43:53,162 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) switched from CREATED to DEPLOYING.
22:43:53,162 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) [DEPLOYING]
22:43:53,162 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) [DEPLOYING].
22:43:53,163 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) [DEPLOYING].
22:43:53,163 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (5/16).
22:43:53,164 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) switched from CREATED to DEPLOYING.
22:43:53,164 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) [DEPLOYING]
22:43:53,164 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) [DEPLOYING].
22:43:53,164 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) [DEPLOYING].
22:43:53,165 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (3/16).
22:43:53,165 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) switched from CREATED to DEPLOYING.
22:43:53,165 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) [DEPLOYING]
22:43:53,165 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) [DEPLOYING].
22:43:53,166 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) [DEPLOYING].
22:43:53,166 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (11/16).
22:43:53,167 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) switched from CREATED to DEPLOYING.
22:43:53,167 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) [DEPLOYING]
22:43:53,167 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) [DEPLOYING].
22:43:53,167 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) [DEPLOYING].
22:43:53,168 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (8/16).
22:43:53,168 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) switched from CREATED to DEPLOYING.
22:43:53,168 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) [DEPLOYING]
22:43:53,168 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) [DEPLOYING].
22:43:53,169 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) [DEPLOYING].
22:43:53,170 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (13/16).
22:43:53,170 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) switched from CREATED to DEPLOYING.
22:43:53,170 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) [DEPLOYING]
22:43:53,170 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) [DEPLOYING].
22:43:53,171 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) [DEPLOYING].
22:43:53,171 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (16/16).
22:43:53,172 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) switched from CREATED to DEPLOYING.
22:43:53,172 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) [DEPLOYING]
22:43:53,172 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) [DEPLOYING].
22:43:53,172 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) [DEPLOYING].
22:43:53,173 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (15/16).
22:43:53,173 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) switched from CREATED to DEPLOYING.
22:43:53,174 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) [DEPLOYING]
22:43:53,174 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) [DEPLOYING].
22:43:53,174 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) [DEPLOYING].
22:43:53,175 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (2/16).
22:43:53,175 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) switched from CREATED to DEPLOYING.
22:43:53,175 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) [DEPLOYING]
22:43:53,175 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) [DEPLOYING].
22:43:53,175 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) [DEPLOYING].
22:43:53,177 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Custom Source (4/16).
22:43:53,177 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) switched from CREATED to DEPLOYING.
22:43:53,177 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) [DEPLOYING]
22:43:53,177 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) [DEPLOYING].
22:43:53,178 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) [DEPLOYING].
22:43:53,179 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Source: Collection Source (1/1).
22:43:53,179 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from CREATED to DEPLOYING.
22:43:53,179 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) [DEPLOYING]
22:43:53,180 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) [DEPLOYING].
22:43:53,180 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) [DEPLOYING].
22:43:53,195 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (16/16).
22:43:53,196 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) switched from CREATED to DEPLOYING.
22:43:53,196 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) [DEPLOYING]
22:43:53,196 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) [DEPLOYING].
22:43:53,197 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) [DEPLOYING].
22:43:53,197 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (15/16).
22:43:53,197 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) switched from CREATED to DEPLOYING.
22:43:53,197 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) [DEPLOYING]
22:43:53,197 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) [DEPLOYING].
22:43:53,198 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) [DEPLOYING].
22:43:53,198 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (14/16).
22:43:53,199 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) switched from CREATED to DEPLOYING.
22:43:53,199 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) [DEPLOYING]
22:43:53,199 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) [DEPLOYING].
22:43:53,199 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) [DEPLOYING].
22:43:53,199 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (13/16).
22:43:53,200 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) switched from CREATED to DEPLOYING.
22:43:53,200 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) [DEPLOYING]
22:43:53,200 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) [DEPLOYING].
22:43:53,200 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) [DEPLOYING].
22:43:53,201 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (12/16).
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) switched from DEPLOYING to RUNNING.
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) switched from CREATED to DEPLOYING.
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) [DEPLOYING]
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) switched from DEPLOYING to RUNNING.
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) [DEPLOYING].
22:43:53,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (15/16) (3024ce0e522a4a712982ef6dacca6d72) switched from DEPLOYING to RUNNING.
22:43:53,201 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) [DEPLOYING].
22:43:53,202 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (13/16) (583f21489159bcd8b51697a5a51b5adf) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (14/16) (009db338a4c5a0955ce74d7b9f5b2df9) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (16/16) (a3a17b4850fbdcb789a6e1da6ff9a348) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (11/16).
22:43:53,202 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (12/16) (94be233330ba70c788d26c918afbeac4) switched from DEPLOYING to RUNNING.
22:43:53,202 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) switched from CREATED to DEPLOYING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) [DEPLOYING]
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) [DEPLOYING].
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (5/16) (0ff972b8dd22aa074429e278f610bc32) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) [DEPLOYING].
22:43:53,203 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (12/16) (70c4e54aeb4cf3922000dc995d72b7dd) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (8/16) (df23a8e3dcba6ce79c298405342e2f8c) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) switched from DEPLOYING to RUNNING.
22:43:53,203 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (15/16) (6ad1333d0f08c975e770de22a0077bab) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (11/16) (be663980e1c002b4f3025a5e7d496daf) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (10/16) (2ef274e07e56fc957b5904015ad67f1b) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (6/16) (67966229679df6a9363ba78aae6e378c) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (3/16) (fd915b2c933253d0b5a47c5f75556baf) switched from DEPLOYING to RUNNING.
22:43:53,204 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (10/16).
22:43:53,205 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (2/16) (fca66eeced13354b0de7fdfa59aba7e6) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) switched from CREATED to DEPLOYING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) [DEPLOYING]
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) [DEPLOYING].
22:43:53,205 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (11/16) (42647bf6729cf9cf6456dde4a193b92b) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) [DEPLOYING].
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) switched from DEPLOYING to RUNNING.
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) switched from DEPLOYING to RUNNING.
22:43:53,205 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) switched from DEPLOYING to RUNNING.
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) switched from DEPLOYING to RUNNING.
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) switched from DEPLOYING to RUNNING.
22:43:53,206 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (9/16).
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) switched from DEPLOYING to RUNNING.
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) switched from CREATED to DEPLOYING.
22:43:53,206 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) [DEPLOYING]
22:43:53,207 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) [DEPLOYING].
22:43:53,207 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) [DEPLOYING].
22:43:53,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (16/16) (2c482779343915286d7c553c8202fbd2) switched from DEPLOYING to RUNNING.
22:43:53,207 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (8/16).
22:43:53,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (7/16) (8128ec72ddee723b3ee9dae7675132e4) switched from DEPLOYING to RUNNING.
22:43:53,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from DEPLOYING to RUNNING.
22:43:53,207 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) switched from DEPLOYING to RUNNING.
22:43:53,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (14/16) (355747995388d0f9c0c33b242fda1eb9) switched from DEPLOYING to RUNNING.
22:43:53,207 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) switched from CREATED to DEPLOYING.
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) [DEPLOYING]
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (9/16) (a425002d51a0366ac9967462f5ad4a8b) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) [DEPLOYING].
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (13/16) (3061d420363508ea904ff6a7bed0c009) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (4/16) (f6be9fbc4160ad3f10b9a1bb7a7768b6) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) [DEPLOYING].
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (10/16) (9a9621a9d454b7e2ba2b3b63581f7117) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (7/16).
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source (1/16) (306ef43e2eb08ed981d82a2193cfb1d7) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (9/16) (70a71fadcfe153f466ac7f2dff62fb37) switched from DEPLOYING to RUNNING.
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) switched from CREATED to DEPLOYING.
22:43:53,208 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)
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) [DEPLOYING]
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) switched from DEPLOYING to RUNNING.
22:43:53,208 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)
22:43:53,208 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)
22:43:53,209 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)
22:43:53,208 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,208 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,208 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)
22:43:53,209 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)
22:43:53,209 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (6/16).
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 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)
22:43:53,209 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (8/16) (119725f4dd5fb992af991bbb0b2d2993) switched from DEPLOYING to RUNNING.
22:43:53,209 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)
22:43:53,208 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)
22:43:53,210 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (5/16).
22:43:53,208 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)
22:43:53,208 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) [DEPLOYING].
22:43:53,208 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)
22:43:53,209 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) switched from CREATED to DEPLOYING.
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) [DEPLOYING]
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) [DEPLOYING].
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) switched from CREATED to DEPLOYING.
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) [DEPLOYING].
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) [DEPLOYING]
22:43:53,210 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) [DEPLOYING].
22:43:53,209 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)
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) [DEPLOYING].
22:43:53,209 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)
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) switched from DEPLOYING to RUNNING.
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) [DEPLOYING].
22:43:53,209 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)
22:43:53,211 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (4/16).
22:43:53,211 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)
22:43:53,211 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (7/16) (764077695a80185d065e22f33e563ec5) switched from DEPLOYING to RUNNING.
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) switched from DEPLOYING to RUNNING.
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) switched from DEPLOYING to RUNNING.
22:43:53,211 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)
22:43:53,211 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)
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) switched from CREATED to DEPLOYING.
22:43:53,211 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) [DEPLOYING]
22:43:53,212 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) [DEPLOYING].
22:43:53,212 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) [DEPLOYING].
22:43:53,211 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (6/16) (b4b79fd09c9e5415b881386793a4ab8d) switched from DEPLOYING to RUNNING.
22:43:53,212 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (5/16) (85d2de6f05029107a8d5634daa42df18) switched from DEPLOYING to RUNNING.
22:43:53,212 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) switched from DEPLOYING to RUNNING.
22:43:53,212 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)
22:43:53,212 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (3/16).
22:43:53,214 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (4/16) (d6245edcbd5111bc8ed4f8bd7ec9ea8f) switched from DEPLOYING to RUNNING.
22:43:53,216 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (2/16).
22:43:53,217 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) switched from CREATED to DEPLOYING.
22:43:53,217 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) [DEPLOYING]
22:43:53,217 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) [DEPLOYING].
22:43:53,217 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) [DEPLOYING].
22:43:53,218 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) switched from DEPLOYING to RUNNING.
22:43:53,218 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)
22:43:53,219 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Received task Co-Process -> Sink: Print to Std. Out (1/16).
22:43:53,220 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (3/16) (4412dc243062d1e07f9b9a247aa643e2) switched from DEPLOYING to RUNNING.
22:43:53,220 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) switched from CREATED to DEPLOYING.
22:43:53,220 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) [DEPLOYING]
22:43:53,220 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) [DEPLOYING].
22:43:53,220 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) [DEPLOYING].
22:43:53,221 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) switched from DEPLOYING to RUNNING.
22:43:53,221 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)
22:43:53,221 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (2/16) (2d7a8a1d52418a6f00838410531f33d5) switched from DEPLOYING to RUNNING.
22:43:53,225 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) switched from CREATED to DEPLOYING.
22:43:53,225 INFO  org.apache.flink.runtime.taskmanager.Task                     - Creating FileSystem stream leak safety net for task Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) [DEPLOYING]
22:43:53,225 INFO  org.apache.flink.runtime.taskmanager.Task                     - Loading JAR files for task Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) [DEPLOYING].
22:43:53,225 INFO  org.apache.flink.runtime.taskmanager.Task                     - Registering task at network: Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) [DEPLOYING].
22:43:53,226 INFO  org.apache.flink.runtime.taskmanager.Task                     - Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) switched from DEPLOYING to RUNNING.
22:43:53,226 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)
22:43:53,227 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Co-Process -> Sink: Print to Std. Out (1/16) (5c9a610c6eef0b2643eda91e1b18bb4b) switched from DEPLOYING to RUNNING.
22:43:53,260 INFO  org.apache.flink.runtime.taskmanager.Task                     - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from RUNNING to FINISHED.
22:43:53,260 INFO  org.apache.flink.runtime.taskmanager.Task                     - Freeing task resources for Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35).
22:43:53,260 INFO  org.apache.flink.runtime.taskmanager.Task                     - Ensuring all FileSystem streams are closed for task Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) [FINISHED]
22:43:53,260 INFO  org.apache.flink.runtime.taskexecutor.TaskExecutor            - Un-registering task and sending final execution state FINISHED to JobManager for task Source: Collection Source 3b71db4a2044f4b218a30ff12ef69d35.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,261 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,261 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,261 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,261 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,260 INFO  org.apache.flink.runtime.state.heap.HeapKeyedStateBackend     - Initializing heap keyed state backend with stream factory.
22:43:53,266 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Collection Source (1/1) (3b71db4a2044f4b218a30ff12ef69d35) switched from RUNNING to FINISHED.
update forwarding to true...
update forwarding to true...
remove old timer...
remove old timer...
4> SensorReading(sensor_2,1593755033242,56.98491298403053)
13> SensorReading(sensor_7,1593755033242,42.46272557043106)
13> SensorReading(sensor_7,1593755033357,42.20636713152061)
4> SensorReading(sensor_2,1593755033357,56.96152873993301)
4> SensorReading(sensor_2,1593755033462,56.86792606406881)
13> SensorReading(sensor_7,1593755033462,42.190478825209944)
4> SensorReading(sensor_2,1593755033562,56.23719305538558)
13> SensorReading(sensor_7,1593755033562,42.30522365777186)
4> SensorReading(sensor_2,1593755033664,56.10997985263106)
13> SensorReading(sensor_7,1593755033664,42.683961844471995)
4> SensorReading(sensor_2,1593755033767,55.44477667995917)
13> SensorReading(sensor_7,1593755033767,43.2590533565345)
13> SensorReading(sensor_7,1593755033871,43.48812356087313)
4> SensorReading(sensor_2,1593755033871,55.87370319980671)
4> SensorReading(sensor_2,1593755033974,55.22167656411897)
13> SensorReading(sensor_7,1593755033974,44.1223632050674)
4> SensorReading(sensor_2,1593755034078,55.29587208804661)
13> SensorReading(sensor_7,1593755034078,45.11097250323669)
13> SensorReading(sensor_7,1593755034182,45.895123887339984)
4> SensorReading(sensor_2,1593755034182,55.08698327162526)
13> SensorReading(sensor_7,1593755034285,46.43517463483627)
4> SensorReading(sensor_2,1593755034285,54.799946531199105)
4> SensorReading(sensor_2,1593755034388,54.62963797263761)
13> SensorReading(sensor_7,1593755034388,46.29939484632749)
4> SensorReading(sensor_2,1593755034493,54.48133466995621)
13> SensorReading(sensor_7,1593755034493,46.447008578061684)
4> SensorReading(sensor_2,1593755034598,55.08000587306544)
13> SensorReading(sensor_7,1593755034598,46.75031490054243)
4> SensorReading(sensor_2,1593755034702,54.16425065891686)
13> SensorReading(sensor_7,1593755034702,47.2946232061483)
4> SensorReading(sensor_2,1593755034808,54.222200815022376)
13> SensorReading(sensor_7,1593755034808,47.02562712212049)
13> SensorReading(sensor_7,1593755034912,46.64874318920291)
4> SensorReading(sensor_2,1593755034912,54.85613884224737)
4> SensorReading(sensor_2,1593755035013,54.15376274803308)
13> SensorReading(sensor_7,1593755035013,46.85298150193249)
4> SensorReading(sensor_2,1593755035117,53.85111382584089)
13> SensorReading(sensor_7,1593755035117,47.39828585403263)
4> SensorReading(sensor_2,1593755035221,54.80149730797952)
13> SensorReading(sensor_7,1593755035221,47.238654013801266)
4> SensorReading(sensor_2,1593755035324,54.676544846987994)
13> SensorReading(sensor_7,1593755035324,46.872687405292154)
4> SensorReading(sensor_2,1593755035428,55.14844328757435)
13> SensorReading(sensor_7,1593755035428,46.91194398329578)
13> SensorReading(sensor_7,1593755035532,47.38973726072569)
4> SensorReading(sensor_2,1593755035532,55.271062749831636)
4> SensorReading(sensor_2,1593755035633,55.55142829307391)
13> SensorReading(sensor_7,1593755035633,48.28100572725862)
13> SensorReading(sensor_7,1593755035737,47.90378197575885)
4> SensorReading(sensor_2,1593755035737,56.68962892711723)
4> SensorReading(sensor_2,1593755035842,56.207961176096774)
13> SensorReading(sensor_7,1593755035842,47.149612591216176)
13> SensorReading(sensor_7,1593755035945,47.088496401176755)
4> SensorReading(sensor_2,1593755035945,55.91613922566888)
4> SensorReading(sensor_2,1593755036047,54.72972335594656)
13> SensorReading(sensor_7,1593755036047,46.891779258605084)
4> SensorReading(sensor_2,1593755036150,54.823170118465704)
13> SensorReading(sensor_7,1593755036150,46.63621103398507)
4> SensorReading(sensor_2,1593755036254,54.32406675396745)
13> SensorReading(sensor_7,1593755036254,46.58920168943597)
4> SensorReading(sensor_2,1593755036359,53.672047920179246)
13> SensorReading(sensor_7,1593755036359,45.59318824616806)
13> SensorReading(sensor_7,1593755036462,45.787225581440154)
4> SensorReading(sensor_2,1593755036462,54.08640299903141)
13> SensorReading(sensor_7,1593755036563,45.310815444583646)
4> SensorReading(sensor_2,1593755036563,54.325329154972636)
4> SensorReading(sensor_2,1593755036666,54.26375578845492)
13> SensorReading(sensor_7,1593755036666,45.37206092048859)
4> SensorReading(sensor_2,1593755036770,54.49132677600722)
13> SensorReading(sensor_7,1593755036770,45.97555158725896)
13> SensorReading(sensor_7,1593755036870,46.37462470162833)
4> SensorReading(sensor_2,1593755036870,53.58979662384507)
4> SensorReading(sensor_2,1593755036974,54.114437602721424)
13> SensorReading(sensor_7,1593755036974,46.37196389109053)
4> SensorReading(sensor_2,1593755037078,53.73016894352684)
13> SensorReading(sensor_7,1593755037078,45.76798984206247)
13> SensorReading(sensor_7,1593755037183,45.74384251307975)
4> SensorReading(sensor_2,1593755037183,53.253079362482175)
4> SensorReading(sensor_2,1593755037286,53.81556353853218)
13> SensorReading(sensor_7,1593755037286,45.02024879705284)
4> SensorReading(sensor_2,1593755037391,53.02925087190296)
13> SensorReading(sensor_7,1593755037391,44.91373702474017)
13> SensorReading(sensor_7,1593755037495,45.140579242793095)
4> SensorReading(sensor_2,1593755037495,53.86667643831486)
4> SensorReading(sensor_2,1593755037598,53.486829480796764)
13> SensorReading(sensor_7,1593755037598,44.80710286900552)
4> SensorReading(sensor_2,1593755037700,53.65630110340394)
13> SensorReading(sensor_7,1593755037700,44.895221557961605)
13> SensorReading(sensor_7,1593755037803,44.14942129715829)
4> SensorReading(sensor_2,1593755037803,53.630250734436075)
4> SensorReading(sensor_2,1593755037905,53.90831433154499)
13> SensorReading(sensor_7,1593755037905,43.83495837308105)
4> SensorReading(sensor_2,1593755038007,54.01921305375246)
13> SensorReading(sensor_7,1593755038007,44.34464444746588)
13> SensorReading(sensor_7,1593755038111,46.18616098656747)
4> SensorReading(sensor_2,1593755038111,54.31523727497167)
13> SensorReading(sensor_7,1593755038217,46.13566801437778)
4> SensorReading(sensor_2,1593755038217,54.8700728239359)
13> SensorReading(sensor_7,1593755038319,46.61827779086269)
4> SensorReading(sensor_2,1593755038319,55.03829961180306)
4> SensorReading(sensor_2,1593755038423,54.87179899814825)
13> SensorReading(sensor_7,1593755038423,46.96410074046941)
13> SensorReading(sensor_7,1593755038527,47.08767046270045)
4> SensorReading(sensor_2,1593755038527,55.32421553617591)
4> SensorReading(sensor_2,1593755038631,54.696799963634085)
13> SensorReading(sensor_7,1593755038631,47.12394635040358)
13> SensorReading(sensor_7,1593755038736,47.06460759552782)
4> SensorReading(sensor_2,1593755038736,54.084388083646026)
4> SensorReading(sensor_2,1593755038840,53.416418513959194)
13> SensorReading(sensor_7,1593755038840,47.77147155022092)
13> SensorReading(sensor_7,1593755038945,47.81754657026653)
4> SensorReading(sensor_2,1593755038945,53.47224148452699)
13> SensorReading(sensor_7,1593755039048,46.943315935027606)
4> SensorReading(sensor_2,1593755039048,53.89977196393901)
4> SensorReading(sensor_2,1593755039153,53.86887211917827)
13> SensorReading(sensor_7,1593755039153,47.929276624855575)
13> SensorReading(sensor_7,1593755039255,47.79524530562536)
4> SensorReading(sensor_2,1593755039255,52.9361260891946)
4> SensorReading(sensor_2,1593755039356,53.167846162507686)
13> SensorReading(sensor_7,1593755039356,48.314515772781874)
4> SensorReading(sensor_2,1593755039461,53.01842264349354)
13> SensorReading(sensor_7,1593755039461,48.18677551720135)
4> SensorReading(sensor_2,1593755039564,53.225303080623156)
13> SensorReading(sensor_7,1593755039564,47.25483670415368)
4> SensorReading(sensor_2,1593755039669,52.93037426239292)
13> SensorReading(sensor_7,1593755039669,47.8531724573362)
13> SensorReading(sensor_7,1593755039773,48.447168903001)
4> SensorReading(sensor_2,1593755039773,53.50779370887109)
4> SensorReading(sensor_2,1593755039878,53.4979564947344)
13> SensorReading(sensor_7,1593755039878,48.422021742490585)
13> SensorReading(sensor_7,1593755039982,48.21309235881405)
4> SensorReading(sensor_2,1593755039982,53.81596920312196)
13> SensorReading(sensor_7,1593755040087,48.14924761138866)
4> SensorReading(sensor_2,1593755040087,54.12014741932983)
13> SensorReading(sensor_7,1593755040189,47.54404101079464)
4> SensorReading(sensor_2,1593755040189,54.0233094156205)
4> SensorReading(sensor_2,1593755040292,53.70043695160367)
13> SensorReading(sensor_7,1593755040292,47.31922248225473)
4> SensorReading(sensor_2,1593755040395,53.45349624400033)
13> SensorReading(sensor_7,1593755040395,48.024023709311784)
13> SensorReading(sensor_7,1593755040495,47.8509629508567)
4> SensorReading(sensor_2,1593755040495,53.344938551402116)
13> SensorReading(sensor_7,1593755040597,48.56048107959864)
4> SensorReading(sensor_2,1593755040597,52.554487230341344)
4> SensorReading(sensor_2,1593755040697,51.54716195467756)
13> SensorReading(sensor_7,1593755040697,49.498574738286564)
4> SensorReading(sensor_2,1593755040799,51.5862738467966)
13> SensorReading(sensor_7,1593755040799,49.47726489714619)
4> SensorReading(sensor_2,1593755040904,51.62767811575464)
13> SensorReading(sensor_7,1593755040904,50.69876890426867)
13> SensorReading(sensor_7,1593755041008,50.87939045853077)
4> SensorReading(sensor_2,1593755041008,51.741708728106545)
4> SensorReading(sensor_2,1593755041111,51.348896223655714)
13> SensorReading(sensor_7,1593755041111,50.476607111672664)
4> SensorReading(sensor_2,1593755041215,51.87592036103323)
13> SensorReading(sensor_7,1593755041215,49.62203632692166)
4> SensorReading(sensor_2,1593755041317,52.15086102692486)
13> SensorReading(sensor_7,1593755041317,49.69338584317635)
4> SensorReading(sensor_2,1593755041419,52.28769368525471)
13> SensorReading(sensor_7,1593755041419,50.55026213509067)
13> SensorReading(sensor_7,1593755041520,50.599301821895075)
4> SensorReading(sensor_2,1593755041520,52.27344901519654)
13> SensorReading(sensor_7,1593755041621,49.819620942336584)
4> SensorReading(sensor_2,1593755041621,51.98297673505681)
4> SensorReading(sensor_2,1593755041721,52.63335002379554)
13> SensorReading(sensor_7,1593755041721,49.556468196996704)
13> SensorReading(sensor_7,1593755041824,49.73210875449282)
4> SensorReading(sensor_2,1593755041824,53.86228684412958)
13> SensorReading(sensor_7,1593755041929,49.71019685324587)
4> SensorReading(sensor_2,1593755041929,53.27423329907586)
13> SensorReading(sensor_7,1593755042032,50.349385269745255)
4> SensorReading(sensor_2,1593755042032,52.381616464680185)
4> SensorReading(sensor_2,1593755042136,52.9588182445311)
13> SensorReading(sensor_7,1593755042136,50.16441744550618)
13> SensorReading(sensor_7,1593755042237,49.57200765049811)
4> SensorReading(sensor_2,1593755042237,53.08012199675541)
4> SensorReading(sensor_2,1593755042341,53.453712381045555)
13> SensorReading(sensor_7,1593755042341,49.183938392447374)
4> SensorReading(sensor_2,1593755042445,53.665584212728355)
13> SensorReading(sensor_7,1593755042445,49.511642402656854)
13> SensorReading(sensor_7,1593755042545,49.59057133672364)
4> SensorReading(sensor_2,1593755042545,53.78352724887037)
13> SensorReading(sensor_7,1593755042647,49.2967478956475)
4> SensorReading(sensor_2,1593755042647,53.76197606427289)
4> SensorReading(sensor_2,1593755042749,53.200816577373956)
13> SensorReading(sensor_7,1593755042749,49.63877200762031)
4> SensorReading(sensor_2,1593755042853,53.40114858300179)
13> SensorReading(sensor_7,1593755042853,50.422548675577914)
4> SensorReading(sensor_2,1593755042957,53.3949041359223)
13> SensorReading(sensor_7,1593755042957,48.75140615585255)
4> SensorReading(sensor_2,1593755043061,53.386257940279656)
13> SensorReading(sensor_7,1593755043061,48.65699378546327)
4> SensorReading(sensor_2,1593755043163,53.32746610781889)
13> SensorReading(sensor_7,1593755043163,48.1192067474568)
13> SensorReading(sensor_7,1593755043264,48.29647916407783)
4> SensorReading(sensor_2,1593755043264,53.42005262050842)
clear forwarding and clear...
13> SensorReading(sensor_7,1593755043368,48.55810254362017)
13> SensorReading(sensor_7,1593755043471,49.40547960561344)
13> SensorReading(sensor_7,1593755043571,49.887882275554055)
13> SensorReading(sensor_7,1593755043673,49.49555676149341)
13> SensorReading(sensor_7,1593755043778,49.77103515326652)
13> SensorReading(sensor_7,1593755043879,50.43886991414744)
13> SensorReading(sensor_7,1593755043982,50.351446077471444)
13> SensorReading(sensor_7,1593755044087,50.92540032680103)
13> SensorReading(sensor_7,1593755044189,50.12217246374734)
13> SensorReading(sensor_7,1593755044290,49.391228470633)
13> SensorReading(sensor_7,1593755044394,49.034801156027406)
13> SensorReading(sensor_7,1593755044497,49.16917762390635)
13> SensorReading(sensor_7,1593755044598,48.81221735613378)
13> SensorReading(sensor_7,1593755044701,48.179635859330745)
13> SensorReading(sensor_7,1593755044804,48.40435673226936)
13> SensorReading(sensor_7,1593755044907,48.33428488141827)
13> SensorReading(sensor_7,1593755045011,48.20949012597008)
13> SensorReading(sensor_7,1593755045114,47.92806775778387)
13> SensorReading(sensor_7,1593755045216,48.292598144682835)
13> SensorReading(sensor_7,1593755045320,48.41835307850806)
13> SensorReading(sensor_7,1593755045422,48.70462413132728)
13> SensorReading(sensor_7,1593755045525,48.1822424964864)
13> SensorReading(sensor_7,1593755045628,48.620853638963496)
13> SensorReading(sensor_7,1593755045731,48.010655402856294)
13> SensorReading(sensor_7,1593755045834,47.70856592463574)
13> SensorReading(sensor_7,1593755045938,47.65877162502574)
13> SensorReading(sensor_7,1593755046038,48.14255039184504)
13> SensorReading(sensor_7,1593755046141,49.02564149170328)
13> SensorReading(sensor_7,1593755046245,48.93647192140283)
13> SensorReading(sensor_7,1593755046348,49.38425086652192)
13> SensorReading(sensor_7,1593755046453,48.30587006905842)
13> SensorReading(sensor_7,1593755046557,47.874207563148865)
13> SensorReading(sensor_7,1593755046661,47.07630952404956)
13> SensorReading(sensor_7,1593755046766,47.91674604607249)
13> SensorReading(sensor_7,1593755046869,47.78557583757827)
13> SensorReading(sensor_7,1593755046971,48.31181619361421)
13> SensorReading(sensor_7,1593755047072,48.290071573213545)
13> SensorReading(sensor_7,1593755047177,48.188953088308914)
13> SensorReading(sensor_7,1593755047278,48.443073034937456)
13> SensorReading(sensor_7,1593755047380,48.616254027197776)
13> SensorReading(sensor_7,1593755047482,49.194301365267044)
13> SensorReading(sensor_7,1593755047584,49.33401906751687)
13> SensorReading(sensor_7,1593755047684,49.271209679253026)
13> SensorReading(sensor_7,1593755047787,49.38562218575968)
13> SensorReading(sensor_7,1593755047888,48.36395765553433)
13> SensorReading(sensor_7,1593755047992,48.986655537966655)
13> SensorReading(sensor_7,1593755048094,48.73554253741171)
13> SensorReading(sensor_7,1593755048195,48.14130069325368)
13> SensorReading(sensor_7,1593755048296,48.29085916655256)
13> SensorReading(sensor_7,1593755048398,48.313841891150346)
13> SensorReading(sensor_7,1593755048501,48.061440009831216)
13> SensorReading(sensor_7,1593755048602,47.060975228214645)
13> SensorReading(sensor_7,1593755048706,46.06692349074958)
13> SensorReading(sensor_7,1593755048811,45.70141047791381)
13> SensorReading(sensor_7,1593755048911,45.59948565648909)
13> SensorReading(sensor_7,1593755049015,44.90152263880642)
13> SensorReading(sensor_7,1593755049120,43.872163389391616)
13> SensorReading(sensor_7,1593755049222,43.861238770414936)
13> SensorReading(sensor_7,1593755049323,44.234881204963465)
13> SensorReading(sensor_7,1593755049427,43.54565178547084)
13> SensorReading(sensor_7,1593755049531,43.8839974420286)
13> SensorReading(sensor_7,1593755049633,43.67106470292176)
13> SensorReading(sensor_7,1593755049737,43.96164555844838)
13> SensorReading(sensor_7,1593755049838,43.48587820399718)
13> SensorReading(sensor_7,1593755049940,43.63215675021818)
13> SensorReading(sensor_7,1593755050042,43.666502476017705)
13> SensorReading(sensor_7,1593755050142,43.04528928127339)
13> SensorReading(sensor_7,1593755050245,43.23783777654449)
13> SensorReading(sensor_7,1593755050350,43.49108189322927)
13> SensorReading(sensor_7,1593755050454,44.438688331214486)
13> SensorReading(sensor_7,1593755050555,44.0778669749964)
13> SensorReading(sensor_7,1593755050658,44.02715879110991)
13> SensorReading(sensor_7,1593755050762,43.471997369224475)
13> SensorReading(sensor_7,1593755050866,43.95689845590016)
13> SensorReading(sensor_7,1593755050970,44.52962249500487)
13> SensorReading(sensor_7,1593755051070,44.24681524174082)
13> SensorReading(sensor_7,1593755051173,44.57348166196569)
13> SensorReading(sensor_7,1593755051273,44.786494789916965)
13> SensorReading(sensor_7,1593755051378,44.30465284445651)
13> SensorReading(sensor_7,1593755051478,44.62546417789299)
13> SensorReading(sensor_7,1593755051582,45.01058909490888)
13> SensorReading(sensor_7,1593755051683,45.54394288762354)
13> SensorReading(sensor_7,1593755051785,45.725627820851294)
13> SensorReading(sensor_7,1593755051890,46.158661574958394)
13> SensorReading(sensor_7,1593755051994,46.27948030324423)
13> SensorReading(sensor_7,1593755052098,45.81143080268612)
13> SensorReading(sensor_7,1593755052203,46.24317371955104)
13> SensorReading(sensor_7,1593755052304,46.69077703622848)
13> SensorReading(sensor_7,1593755052407,47.39327688998162)
13> SensorReading(sensor_7,1593755052511,46.8275647600129)
13> SensorReading(sensor_7,1593755052613,45.76983345493303)
13> SensorReading(sensor_7,1593755052717,45.588991243501255)
13> SensorReading(sensor_7,1593755052820,45.68334152335362)
13> SensorReading(sensor_7,1593755052924,46.32633578962223)
13> SensorReading(sensor_7,1593755053028,46.896722207849955)
13> SensorReading(sensor_7,1593755053132,46.429833444785196)
13> SensorReading(sensor_7,1593755053233,46.56368202532942)
13> SensorReading(sensor_7,1593755053337,46.610295412433686)
13> SensorReading(sensor_7,1593755053441,46.618957531167574)
13> SensorReading(sensor_7,1593755053544,45.803330019026575)
13> SensorReading(sensor_7,1593755053646,46.31037544850666)
13> SensorReading(sensor_7,1593755053748,46.33312355570126)
13> SensorReading(sensor_7,1593755053849,46.043660868175564)
13> SensorReading(sensor_7,1593755053953,46.43880960920198)
13> SensorReading(sensor_7,1593755054055,46.76178985393613)
13> SensorReading(sensor_7,1593755054160,46.119683586954146)
13> SensorReading(sensor_7,1593755054261,45.86308788310898)
13> SensorReading(sensor_7,1593755054361,45.342422816572444)
13> SensorReading(sensor_7,1593755054463,46.388083164785165)
13> SensorReading(sensor_7,1593755054566,45.74090951393004)
13> SensorReading(sensor_7,1593755054671,46.20419017181864)
13> SensorReading(sensor_7,1593755054772,46.584430278464026)
13> SensorReading(sensor_7,1593755054872,46.81257537914236)
13> SensorReading(sensor_7,1593755054977,46.15775287445955)
13> SensorReading(sensor_7,1593755055077,46.386031012647535)
13> SensorReading(sensor_7,1593755055182,46.39494872986863)
13> SensorReading(sensor_7,1593755055287,46.19806568633036)
13> SensorReading(sensor_7,1593755055387,46.721757241806884)
13> SensorReading(sensor_7,1593755055491,46.819502759624044)
13> SensorReading(sensor_7,1593755055594,47.055041172069174)
13> SensorReading(sensor_7,1593755055697,47.05035015900962)
13> SensorReading(sensor_7,1593755055802,46.68544815570408)
13> SensorReading(sensor_7,1593755055903,46.962323788485385)
13> SensorReading(sensor_7,1593755056004,46.80833217217676)
13> SensorReading(sensor_7,1593755056104,46.243440938711764)
13> SensorReading(sensor_7,1593755056207,46.12459834125961)
13> SensorReading(sensor_7,1593755056311,45.291955012232556)
13> SensorReading(sensor_7,1593755056415,45.75281912332354)
13> SensorReading(sensor_7,1593755056520,45.79980783238929)
13> SensorReading(sensor_7,1593755056621,45.98677776496325)
13> SensorReading(sensor_7,1593755056724,45.50691772863026)
13> SensorReading(sensor_7,1593755056828,45.09197268449999)
13> SensorReading(sensor_7,1593755056932,45.17815469747456)
13> SensorReading(sensor_7,1593755057036,45.30814072181534)
13> SensorReading(sensor_7,1593755057138,46.12042549910977)
13> SensorReading(sensor_7,1593755057242,44.88130772882044)
13> SensorReading(sensor_7,1593755057343,45.32803107107502)
13> SensorReading(sensor_7,1593755057444,45.70193287859984)
13> SensorReading(sensor_7,1593755057549,45.72882526532534)
13> SensorReading(sensor_7,1593755057653,45.326294653770624)
13> SensorReading(sensor_7,1593755057757,46.063669796321925)
13> SensorReading(sensor_7,1593755057861,45.880218544691196)
13> SensorReading(sensor_7,1593755057965,46.04047034653315)
13> SensorReading(sensor_7,1593755058070,45.69333242959603)
13> SensorReading(sensor_7,1593755058171,44.86437718770916)
13> SensorReading(sensor_7,1593755058273,44.36736626600568)
13> SensorReading(sensor_7,1593755058378,44.317171500717194)
13> SensorReading(sensor_7,1593755058480,44.586554669807704)
13> SensorReading(sensor_7,1593755058580,44.93379352125655)
13> SensorReading(sensor_7,1593755058682,44.61567850944046)
13> SensorReading(sensor_7,1593755058782,44.60222820045661)
13> SensorReading(sensor_7,1593755058886,44.669471340976465)
13> SensorReading(sensor_7,1593755058991,43.97218640957911)
13> SensorReading(sensor_7,1593755059094,44.20067113585008)
13> SensorReading(sensor_7,1593755059196,43.40554659297709)
13> SensorReading(sensor_7,1593755059297,44.49648200349128)
13> SensorReading(sensor_7,1593755059399,44.79256959214062)
13> SensorReading(sensor_7,1593755059503,45.39441774303975)
13> SensorReading(sensor_7,1593755059606,45.51349178460342)
13> SensorReading(sensor_7,1593755059711,45.910391327869256)
13> SensorReading(sensor_7,1593755059812,45.7456192736983)
13> SensorReading(sensor_7,1593755059915,45.70508418335377)
13> SensorReading(sensor_7,1593755060020,46.076094409136346)
13> SensorReading(sensor_7,1593755060121,46.11059997136797)
13> SensorReading(sensor_7,1593755060222,46.07402474090721)
13> SensorReading(sensor_7,1593755060324,45.88932672524596)
13> SensorReading(sensor_7,1593755060424,45.04371438656418)
13> SensorReading(sensor_7,1593755060528,45.45098592161227)
13> SensorReading(sensor_7,1593755060630,45.153889377205786)
13> SensorReading(sensor_7,1593755060732,45.315496150483135)
13> SensorReading(sensor_7,1593755060836,45.27637733892135)
13> SensorReading(sensor_7,1593755060939,45.86341244431646)
13> SensorReading(sensor_7,1593755061040,45.364586237040236)
13> SensorReading(sensor_7,1593755061140,45.955214693250156)
13> SensorReading(sensor_7,1593755061244,45.708810247108005)
13> SensorReading(sensor_7,1593755061345,46.31120919090406)
13> SensorReading(sensor_7,1593755061448,46.538826147694316)
13> SensorReading(sensor_7,1593755061553,47.13917450768823)
13> SensorReading(sensor_7,1593755061654,47.59227089169116)
13> SensorReading(sensor_7,1593755061755,47.58929501746494)
13> SensorReading(sensor_7,1593755061859,47.57288086873687)
13> SensorReading(sensor_7,1593755061959,48.021360824426246)
13> SensorReading(sensor_7,1593755062063,48.52969679903479)
13> SensorReading(sensor_7,1593755062166,47.99902016861536)
13> SensorReading(sensor_7,1593755062270,47.42757952003379)
13> SensorReading(sensor_7,1593755062375,47.42678936444981)
13> SensorReading(sensor_7,1593755062478,47.85464834373825)
13> SensorReading(sensor_7,1593755062581,47.13655800753897)
13> SensorReading(sensor_7,1593755062683,47.856429778824804)
13> SensorReading(sensor_7,1593755062786,48.59626546276741)
13> SensorReading(sensor_7,1593755062891,48.46090292142242)
13> SensorReading(sensor_7,1593755062994,48.742524371502995)
13> SensorReading(sensor_7,1593755063098,49.796261333272135)
13> SensorReading(sensor_7,1593755063203,49.617160511522414)
13> SensorReading(sensor_7,1593755063307,50.026733873313525)
13> SensorReading(sensor_7,1593755063409,50.798940674654496)
13> SensorReading(sensor_7,1593755063511,50.11989059502484)
13> SensorReading(sensor_7,1593755063611,49.766510112246394)
13> SensorReading(sensor_7,1593755063716,50.03133346656084)
13> SensorReading(sensor_7,1593755063820,48.838258946788066)
13> SensorReading(sensor_7,1593755063923,48.91916075559018)
13> SensorReading(sensor_7,1593755064028,47.43464935441561)
13> SensorReading(sensor_7,1593755064128,46.743239067627485)
13> SensorReading(sensor_7,1593755064234,46.400782548271316)
13> SensorReading(sensor_7,1593755064336,47.336610746245405)
13> SensorReading(sensor_7,1593755064436,48.01520104445537)
13> SensorReading(sensor_7,1593755064540,48.21250323217275)
13> SensorReading(sensor_7,1593755064641,48.068081435064656)
13> SensorReading(sensor_7,1593755064744,48.41652024482292)
13> SensorReading(sensor_7,1593755064847,49.17523232316911)
13> SensorReading(sensor_7,1593755064952,49.022987648624074)
13> SensorReading(sensor_7,1593755065053,49.25168876467252)
13> SensorReading(sensor_7,1593755065154,49.367642588981056)
13> SensorReading(sensor_7,1593755065256,49.04513916049078)
13> SensorReading(sensor_7,1593755065359,49.232044778950794)
13> SensorReading(sensor_7,1593755065463,49.187037468154514)
13> SensorReading(sensor_7,1593755065566,49.31833663940524)
13> SensorReading(sensor_7,1593755065668,48.87669309095733)
13> SensorReading(sensor_7,1593755065773,49.0101645060019)
13> SensorReading(sensor_7,1593755065874,48.87730460049866)
13> SensorReading(sensor_7,1593755065978,48.809538767919214)
13> SensorReading(sensor_7,1593755066081,49.824824996183786)
13> SensorReading(sensor_7,1593755066186,49.797534352021934)
13> SensorReading(sensor_7,1593755066288,49.23993131371815)
13> SensorReading(sensor_7,1593755066390,49.07904436462282)
13> SensorReading(sensor_7,1593755066491,48.32224749761525)
13> SensorReading(sensor_7,1593755066594,48.627356169999125)
13> SensorReading(sensor_7,1593755066695,48.33572412742344)
13> SensorReading(sensor_7,1593755066799,48.956151278965145)
13> SensorReading(sensor_7,1593755066903,48.537509770117765)
13> SensorReading(sensor_7,1593755067006,48.16157874523306)
13> SensorReading(sensor_7,1593755067109,47.051365005240136)
13> SensorReading(sensor_7,1593755067210,47.221191258578656)
13> SensorReading(sensor_7,1593755067311,47.81170544556506)
13> SensorReading(sensor_7,1593755067411,47.77745183938537)
13> SensorReading(sensor_7,1593755067511,47.643204644885)
13> SensorReading(sensor_7,1593755067611,46.3921406457174)
13> SensorReading(sensor_7,1593755067714,46.34489587952372)
13> SensorReading(sensor_7,1593755067814,46.799619789467776)
13> SensorReading(sensor_7,1593755067916,47.83395498590612)
13> SensorReading(sensor_7,1593755068020,48.072100914343196)
13> SensorReading(sensor_7,1593755068120,47.766575254416644)
13> SensorReading(sensor_7,1593755068221,47.36470008532658)
13> SensorReading(sensor_7,1593755068324,47.76687164778584)
13> SensorReading(sensor_7,1593755068428,47.68520326702643)
13> SensorReading(sensor_7,1593755068532,46.92624571475342)
13> SensorReading(sensor_7,1593755068637,47.70545632527256)
13> SensorReading(sensor_7,1593755068738,48.1944422565762)
13> SensorReading(sensor_7,1593755068842,48.777541479862485)
13> SensorReading(sensor_7,1593755068945,48.82836752687947)
13> SensorReading(sensor_7,1593755069049,48.520457191094245)
13> SensorReading(sensor_7,1593755069150,48.65439104760059)
13> SensorReading(sensor_7,1593755069252,48.275397646812856)
13> SensorReading(sensor_7,1593755069356,47.77920018895189)
13> SensorReading(sensor_7,1593755069461,47.30140755751055)
13> SensorReading(sensor_7,1593755069564,47.346792721171994)
13> SensorReading(sensor_7,1593755069668,47.58338205383726)
13> SensorReading(sensor_7,1593755069771,48.22781531946084)
13> SensorReading(sensor_7,1593755069874,48.51599523194172)
13> SensorReading(sensor_7,1593755069978,49.55029675494873)
13> SensorReading(sensor_7,1593755070082,49.8774557242574)
13> SensorReading(sensor_7,1593755070186,50.68292984076345)
13> SensorReading(sensor_7,1593755070289,50.72885801512973)
13> SensorReading(sensor_7,1593755070391,51.19549071113051)
13> SensorReading(sensor_7,1593755070494,51.10795804021939)
13> SensorReading(sensor_7,1593755070595,51.67570669509838)
13> SensorReading(sensor_7,1593755070695,51.69551971203892)
13> SensorReading(sensor_7,1593755070796,52.044445092771646)
13> SensorReading(sensor_7,1593755070897,51.49366199441577)
13> SensorReading(sensor_7,1593755071000,51.603072994479774)
13> SensorReading(sensor_7,1593755071103,51.21142380353605)
13> SensorReading(sensor_7,1593755071204,51.392286586302816)
13> SensorReading(sensor_7,1593755071305,51.13264941491199)
13> SensorReading(sensor_7,1593755071408,49.79513838153913)
13> SensorReading(sensor_7,1593755071511,49.401393285579545)
13> SensorReading(sensor_7,1593755071612,49.2778882002076)
13> SensorReading(sensor_7,1593755071716,49.01963609559056)
13> SensorReading(sensor_7,1593755071820,48.27556500536663)
13> SensorReading(sensor_7,1593755071923,48.849533474730265)
13> SensorReading(sensor_7,1593755072027,48.66138878075943)
13> SensorReading(sensor_7,1593755072129,47.9819429873132)
13> SensorReading(sensor_7,1593755072231,48.017662390653506)
13> SensorReading(sensor_7,1593755072335,47.923987925950264)
13> SensorReading(sensor_7,1593755072439,48.76840520698552)
13> SensorReading(sensor_7,1593755072544,48.92806529290009)
13> SensorReading(sensor_7,1593755072646,48.990608844888904)
13> SensorReading(sensor_7,1593755072749,49.54309268006809)
13> SensorReading(sensor_7,1593755072849,49.37077815832152)
13> SensorReading(sensor_7,1593755072953,48.72916232079726)
13> SensorReading(sensor_7,1593755073055,47.952285179057824)
13> SensorReading(sensor_7,1593755073156,46.843187227011434)
13> SensorReading(sensor_7,1593755073261,46.662065003985134)
13> SensorReading(sensor_7,1593755073361,47.45567975011274)
13> SensorReading(sensor_7,1593755073462,47.57606811455359)
22:44:33,558 INFO  org.apache.flink.runtime.blob.TransientBlobCache              - Shutting down BLOB cache
22:44:33,558 INFO  org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager  - Shutting down TaskExecutorLocalStateStoresManager.
22:44:33,559 INFO  org.apache.flink.runtime.blob.PermanentBlobCache              - Shutting down BLOB cache
13> SensorReading(sensor_7,1593755073564,47.52206396816568)
22:44:33,569 INFO  org.apache.flink.runtime.blob.BlobServer                      - Stopped BLOB server at 0.0.0.0:60480
22:44:33,569 INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager          - I/O manager removed spill file directory /var/folders/p1/zjfp5tdd2dn187w0hb7mq9pm0000gp/T/flink-io-192b3f88-2610-45ea-96d8-119774498ca3

Process finished with exit code 1