Skip to content

Instantly share code, notes, and snippets.

@cbweixin

cbweixin/ProcessFunctionTimers

Created July 5, 2020 21:16
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save cbweixin/e55b87159fc29fa8a799b8535deda014 to your computer and use it in GitHub Desktop.
Save cbweixin/e55b87159fc29fa8a799b8535deda014 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
ProcessFunctionTimers
D:\apps\oraclejava8\bin\java.exe "-javaagent:D:\apps\IntelliJ IDEA Community Edition 2020.1.2\lib\idea_rt.jar=51076:D:\apps\IntelliJ IDEA Community Edition 2020.1.2\bin" -Dfile.encoding=UTF-8 -classpath D:\apps\oraclejava8\jre\lib\charsets.jar;D:\apps\oraclejava8\jre\lib\deploy.jar;D:\apps\oraclejava8\jre\lib\ext\access-bridge-64.jar;D:\apps\oraclejava8\jre\lib\ext\cldrdata.jar;D:\apps\oraclejava8\jre\lib\ext\dnsns.jar;D:\apps\oraclejava8\jre\lib\ext\jaccess.jar;D:\apps\oraclejava8\jre\lib\ext\jfxrt.jar;D:\apps\oraclejava8\jre\lib\ext\localedata.jar;D:\apps\oraclejava8\jre\lib\ext\nashorn.jar;D:\apps\oraclejava8\jre\lib\ext\sunec.jar;D:\apps\oraclejava8\jre\lib\ext\sunjce_provider.jar;D:\apps\oraclejava8\jre\lib\ext\sunmscapi.jar;D:\apps\oraclejava8\jre\lib\ext\sunpkcs11.jar;D:\apps\oraclejava8\jre\lib\ext\zipfs.jar;D:\apps\oraclejava8\jre\lib\javaws.jar;D:\apps\oraclejava8\jre\lib\jce.jar;D:\apps\oraclejava8\jre\lib\jfr.jar;D:\apps\oraclejava8\jre\lib\jfxswt.jar;D:\apps\oraclejava8\jre\lib\jsse.jar;D:\apps\oraclejava8\jre\lib\management-agent.jar;D:\apps\oraclejava8\jre\lib\plugin.jar;D:\apps\oraclejava8\jre\lib\resources.jar;D:\apps\oraclejava8\jre\lib\rt.jar;D:\github\streaming-with-flink\examples-scala\target\classes;D:\apps\.m2\org\apache\flink\flink-scala_2.12\1.7.1\flink-scala_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-core\1.7.1\flink-core-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-annotations\1.7.1\flink-annotations-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-metrics-core\1.7.1\flink-metrics-core-1.7.1.jar;D:\apps\.m2\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;D:\apps\.m2\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;D:\apps\.m2\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;D:\apps\.m2\org\objenesis\objenesis\2.1\objenesis-2.1.jar;D:\apps\.m2\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;D:\apps\.m2\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar;D:\apps\.m2\org\tukaani\xz\1.0\xz-1.0.jar;D:\apps\.m2\org\apache\flink\flink-java\1.7.1\flink-java-1.7.1.jar;D:\apps\.m2\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;D:\apps\.m2\org\apache\flink\flink-shaded-asm\5.0.4-5.0\flink-shaded-asm-5.0.4-5.0.jar;D:\apps\.m2\org\apache\flink\flink-shaded-asm-6\6.2.1-5.0\flink-shaded-asm-6-6.2.1-5.0.jar;D:\apps\.m2\org\scala-lang\scala-reflect\2.12.7\scala-reflect-2.12.7.jar;D:\apps\.m2\org\scala-lang\scala-compiler\2.12.7\scala-compiler-2.12.7.jar;D:\apps\.m2\org\scala-lang\modules\scala-xml_2.12\1.0.6\scala-xml_2.12-1.0.6.jar;D:\apps\.m2\org\slf4j\slf4j-api\1.7.15\slf4j-api-1.7.15.jar;D:\apps\.m2\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;D:\apps\.m2\org\apache\flink\force-shading\1.7.1\force-shading-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-streaming-scala_2.12\1.7.1\flink-streaming-scala_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-streaming-java_2.12\1.7.1\flink-streaming-java_2.12-1.7.1.jar;D:\apps\.m2\org\scala-lang\scala-library\2.12.8\scala-library-2.12.8.jar;D:\apps\.m2\org\apache\flink\flink-runtime-web_2.12\1.7.1\flink-runtime-web_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-runtime_2.12\1.7.1\flink-runtime_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-hadoop-fs\1.7.1\flink-hadoop-fs-1.7.1.jar;D:\apps\.m2\commons-io\commons-io\2.4\commons-io-2.4.jar;D:\apps\.m2\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;D:\apps\.m2\com\typesafe\akka\akka-actor_2.12\2.4.20\akka-actor_2.12-2.4.20.jar;D:\apps\.m2\com\typesafe\config\1.3.0\config-1.3.0.jar;D:\apps\.m2\org\scala-lang\modules\scala-java8-compat_2.12\0.8.0\scala-java8-compat_2.12-0.8.0.jar;D:\apps\.m2\com\typesafe\akka\akka-stream_2.12\2.4.20\akka-stream_2.12-2.4.20.jar;D:\apps\.m2\org\reactivestreams\reactive-streams\1.0.0\reactive-streams-1.0.0.jar;D:\apps\.m2\com\typesafe\ssl-config-core_2.12\0.2.1\ssl-config-core_2.12-0.2.1.jar;D:\apps\.m2\org\scala-lang\modules\scala-parser-combinators_2.12\1.0.4\scala-parser-combinators_2.12-1.0.4.jar;D:\apps\.m2\com\typesafe\akka\akka-protobuf_2.12\2.4.20\akka-protobuf_2.12-2.4.20.jar;D:\apps\.m2\com\typesafe\akka\akka-slf4j_2.12\2.4.20\akka-slf4j_2.12-2.4.20.jar;D:\apps\.m2\org\clapper\grizzled-slf4j_2.12\1.3.2\grizzled-slf4j_2.12-1.3.2.jar;D:\apps\.m2\com\github\scopt\scopt_2.12\3.5.0\scopt_2.12-3.5.0.jar;D:\apps\.m2\org\xerial\snappy\snappy-java\1.1.4\snappy-java-1.1.4.jar;D:\apps\.m2\com\twitter\chill_2.12\0.7.6\chill_2.12-0.7.6.jar;D:\apps\.m2\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;D:\apps\.m2\org\apache\flink\flink-clients_2.12\1.7.1\flink-clients_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-optimizer_2.12\1.7.1\flink-optimizer_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-shaded-netty\4.1.24.Final-5.0\flink-shaded-netty-4.1.24.Final-5.0.jar;D:\apps\.m2\org\apache\flink\flink-shaded-guava\18.0-5.0\flink-shaded-guava-18.0-5.0.jar;D:\apps\.m2\org\apache\flink\flink-shaded-jackson\2.7.9-5.0\flink-shaded-jackson-2.7.9-5.0.jar;D:\apps\.m2\org\javassist\javassist\3.19.0-GA\javassist-3.19.0-GA.jar;D:\apps\.m2\org\apache\flink\flink-queryable-state-runtime_2.12\1.7.1\flink-queryable-state-runtime_2.12-1.7.1.jar;D:\apps\.m2\org\apache\flink\flink-queryable-state-client-java_2.12\1.7.1\flink-queryable-state-client-java_2.12-1.7.1.jar;D:\apps\.m2\org\apache\derby\derby\10.13.1.1\derby-10.13.1.1.jar;D:\apps\.m2\org\slf4j\slf4j-log4j12\1.7.25\slf4j-log4j12-1.7.25.jar;D:\apps\.m2\log4j\log4j\1.2.17\log4j-1.2.17.jar io.github.streamingwithflink.chapter6.ProcessFunctionTimers
14:14:52,301 INFO org.apache.flink.api.java.typeutils.TypeExtractor - class io.github.streamingwithflink.util.SensorReading does not contain a setter for field id
14:14:52,327 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.
14:14:52,819 INFO org.apache.flink.streaming.api.environment.LocalStreamEnvironment - Running job on local embedded Flink mini cluster
14:14:52,866 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
14:14:52,947 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
14:14:53,032 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported.
14:14:53,104 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
14:14:53,651 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
14:14:53,680 INFO org.apache.flink.runtime.minicluster.MiniCluster - Trying to start actor system at :0
14:14:53,786 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
14:14:53,896 INFO akka.remote.Remoting - Starting remoting
14:14:54,359 INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink-metrics@192.168.56.1:51093]
14:14:54,396 INFO org.apache.flink.runtime.minicluster.MiniCluster - Actor system started at akka.tcp://flink-metrics@192.168.56.1:51093
14:14:54,401 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability services
14:14:54,461 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory C:\Users\weitong\AppData\Local\Temp\blobStore-47dc5db1-a85a-4e6c-b827-bd9813fe8b5f
14:14:54,468 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:51094 - max concurrent requests: 50 - max backlog: 1000
14:14:54,470 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting ResourceManger
14:14:54,506 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341 .
14:14:54,518 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.resourcemanager.StandaloneResourceManager@101639ae @ akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341
14:14:54,520 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341 was granted leadership with fencing token 8317ab4c67077977c81f6a86353049ae
14:14:54,520 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the SlotManager.
14:14:54,522 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341 , session=c81f6a86-3530-49ae-8317-ab4c67077977
14:14:54,522 INFO org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage directory C:\Users\weitong\AppData\Local\Temp\blobStore-a73c4429-0511-46de-b08d-e3def7fea4e7
14:14:54,523 INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory C:\Users\weitong\AppData\Local\Temp\blobStore-685a627e-1d23-464a-8f3b-71b811fc44f6
14:14:54,523 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
14:14:54,526 INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager with ResourceID: 79d521d0-4b94-4b78-bbc6-89098ef127da
14:14:54,576 INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file directory 'C:\Users\weitong\AppData\Local\Temp': total 237 GB, usable 177 GB (74.68% usable)
14:14:54,764 INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 300 MB for network buffer pool (number of memory segments: 9628, bytes per segment: 32768).
14:14:54,821 INFO org.apache.flink.runtime.io.network.NetworkEnvironment - Starting the network environment and its components.
14:14:55,471 INFO org.apache.flink.queryablestate.server.KvStateServerImpl - Started Queryable State Server @ /127.0.0.1:9067.
14:14:55,481 INFO org.apache.flink.queryablestate.client.proxy.KvStateClientProxyImpl - Started Queryable State Proxy Server @ /127.0.0.1:9069.
14:14:55,484 WARN org.apache.flink.runtime.taskmanager.TaskManagerLocation - No hostname could be resolved for the IP address 127.0.0.1, using IP address as host name. Local input split assignment (such as for HDFS files) may be impacted.
14:14:55,484 INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Limiting managed memory to 0.7 of the currently free heap space (1888 MB), memory will be allocated lazily.
14:14:55,502 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager uses directory C:\Users\weitong\AppData\Local\Temp\flink-io-ee514c39-9efc-4dfd-8a83-232c5ca0d86a for spill files.
14:14:55,527 INFO org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messages have a max timeout of 10000 ms
14:14:55,538 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/taskmanager_0 .
14:14:55,546 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Start job leader service.
14:14:55,547 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341(8317ab4c67077977c81f6a86353049ae).
14:14:55,548 INFO org.apache.flink.runtime.filecache.FileCache - User file cache uses directory C:\Users\weitong\AppData\Local\Temp\flink-dist-cache-b620807a-44f2-48ec-8afa-a660aa19d1f5
14:14:55,548 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting dispatcher rest endpoint.
14:14:55,569 WARN org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Upload directory C:\Users\weitong\AppData\Local\Temp\flink-web-upload does not exist, or has been deleted externally. Previously uploaded files are no longer available.
14:14:55,571 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager address, beginning registration
14:14:55,571 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager attempt 1 (timeout=100ms)
14:14:55,585 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Created directory C:\Users\weitong\AppData\Local\Temp\flink-web-upload for file uploads.
14:14:55,588 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering TaskManager with ResourceID 79d521d0-4b94-4b78-bbc6-89098ef127da (akka://flink/user/taskmanager_0) at ResourceManager
14:14:55,589 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at resource manager akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341 under registration id bdc157e8e9c03581f5297fab474953c9.
14:14:55,635 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest endpoint.
14:14:55,949 WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment variable 'log.file' is not set.
14:14:55,950 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])'.
14:14:55,984 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at localhost:51158
14:14:55,984 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint@1e411d81 @ http://localhost:51158
14:14:55,984 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://localhost:51158.
14:14:55,984 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:51158 was granted leadership with leaderSessionID=5ca982b4-008f-490f-9e8c-ee1bba04fdb8
14:14:55,984 INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting job dispatcher(s) for JobManger
14:14:55,984 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:51158 , session=5ca982b4-008f-490f-9e8c-ee1bba04fdb8
14:14:56,004 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher4dc5bcf0-be94-4378-a43d-4bbb1c4551de .
14:14:56,021 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.dispatcher.StandaloneDispatcher@48b0e701 @ akka://flink/user/dispatcher4dc5bcf0-be94-4378-a43d-4bbb1c4551de
14:14:56,021 INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
14:14:56,022 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka://flink/user/dispatcher4dc5bcf0-be94-4378-a43d-4bbb1c4551de was granted leadership with fencing token 00edf8f5-d110-40fa-a227-7a090842f0b4
14:14:56,023 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs.
14:14:56,034 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher4dc5bcf0-be94-4378-a43d-4bbb1c4551de , session=00edf8f5-d110-40fa-a227-7a090842f0b4
14:14:56,041 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 3e492b544d201d02fb732e729ef94ed8 (Monitor sensor temperatures.).
14:14:56,062 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_1 .
14:14:56,071 INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8).
14:14:56,075 INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy NoRestartStrategy for Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8).
14:14:56,079 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/aff936af-09f5-4970-81e3-0542b630a5ff .
14:14:56,112 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
14:14:56,149 INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8).
14:14:56,149 INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms.
14:14:56,177 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)
14:14:56,184 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender org.apache.flink.runtime.jobmaster.JobManagerRunner@699c5a9 @ akka://flink/user/jobmanager_1
14:14:56,184 INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8) was granted leadership with session id 1e067737-ee6c-4f01-816d-074c4fa51cb9 at akka://flink/user/jobmanager_1.
14:14:56,194 INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8)
14:14:56,203 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Monitor sensor temperatures. (3e492b544d201d02fb732e729ef94ed8) switched from state CREATED to RUNNING.
14:14:56,206 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) switched from CREATED to SCHEDULED.
14:14:56,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) switched from CREATED to SCHEDULED.
14:14:56,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) switched from CREATED to SCHEDULED.
14:14:56,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) switched from CREATED to SCHEDULED.
14:14:56,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) switched from CREATED to SCHEDULED.
14:14:56,211 INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_1 , session=1e067737-ee6c-4f01-816d-074c4fa51cb9
14:14:56,231 INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager_bce101a0-fc22-4e9d-8f4e-da6ea038c341(8317ab4c67077977c81f6a86353049ae)
14:14:56,241 INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
14:14:56,241 INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms)
14:14:56,243 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager 816d074c4fa51cb91e067737ee6c4f01@akka://flink/user/jobmanager_1 for job 3e492b544d201d02fb732e729ef94ed8.
14:14:56,244 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{711b509569dbf26108cee27f13707c16}]
14:14:56,246 INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager 816d074c4fa51cb91e067737ee6c4f01@akka://flink/user/jobmanager_1 for job 3e492b544d201d02fb732e729ef94ed8.
14:14:56,247 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{17280bd3d948d9e05becccddd5152df6}]
14:14:56,247 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{d37901e21cb0f4059b1d520b3427099b}]
14:14:56,247 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{022b6cc0c16c760b3d8d47b9ca642e52}]
14:14:56,247 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{bf141975e3c2c5e279f2f844fd0cbd39}]
14:14:56,247 INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: 8317ab4c67077977c81f6a86353049ae.
14:14:56,248 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{9c95448972145cab4ee2932c1be9bfc5}]
14:14:56,248 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{17280bd3d948d9e05becccddd5152df6}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,249 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{67a38689156e793dca102d8f7ada5e3d}.
14:14:56,249 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{9c95448972145cab4ee2932c1be9bfc5}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,249 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{bf141975e3c2c5e279f2f844fd0cbd39}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,249 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{711b509569dbf26108cee27f13707c16}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,250 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{d37901e21cb0f4059b1d520b3427099b}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,250 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{022b6cc0c16c760b3d8d47b9ca642e52}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager.
14:14:56,250 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{67a38689156e793dca102d8f7ada5e3d} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,251 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{eeafe7c5cdc21abeca695c1110bb0bab}.
14:14:56,251 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{67a38689156e793dca102d8f7ada5e3d}.
14:14:56,251 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,251 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{29cbd08634f2a2a4c8a152b5d261663c}.
14:14:56,251 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{29d0094c2ce483217cb0f5321f71bd2a}.
14:14:56,252 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{224c78950cbbfa9cccf0248988ed2133}.
14:14:56,252 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 3e492b544d201d02fb732e729ef94ed8 with allocation id AllocationID{d58422194d2fdba279ea19fa4674efaf}.
14:14:56,252 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{eeafe7c5cdc21abeca695c1110bb0bab} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,252 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{eeafe7c5cdc21abeca695c1110bb0bab}.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 1e067737-ee6c-4f01-816d-074c4fa51cb9.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{29cbd08634f2a2a4c8a152b5d261663c} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{29cbd08634f2a2a4c8a152b5d261663c}.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 1e067737-ee6c-4f01-816d-074c4fa51cb9.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{29d0094c2ce483217cb0f5321f71bd2a} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{29d0094c2ce483217cb0f5321f71bd2a}.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{224c78950cbbfa9cccf0248988ed2133} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,253 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{224c78950cbbfa9cccf0248988ed2133}.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 1e067737-ee6c-4f01-816d-074c4fa51cb9.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request AllocationID{d58422194d2fdba279ea19fa4674efaf} for job 3e492b544d201d02fb732e729ef94ed8 from resource manager with leader id 8317ab4c67077977c81f6a86353049ae.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 1e067737-ee6c-4f01-816d-074c4fa51cb9.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for AllocationID{d58422194d2fdba279ea19fa4674efaf}.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 3e492b544d201d02fb732e729ef94ed8 for job leader monitoring.
14:14:56,254 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 1e067737-ee6c-4f01-816d-074c4fa51cb9.
14:14:56,255 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
14:14:56,255 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)
14:14:56,255 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
14:14:56,257 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at JobManager attempt 1 (timeout=100ms)
14:14:56,258 INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful registration at job manager akka://flink/user/jobmanager_1 for job 3e492b544d201d02fb732e729ef94ed8.
14:14:56,259 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job 3e492b544d201d02fb732e729ef94ed8.
14:14:56,261 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job 3e492b544d201d02fb732e729ef94ed8.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{29d0094c2ce483217cb0f5321f71bd2a}.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{67a38689156e793dca102d8f7ada5e3d}.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{224c78950cbbfa9cccf0248988ed2133}.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{29cbd08634f2a2a4c8a152b5d261663c}.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{d58422194d2fdba279ea19fa4674efaf}.
14:14:56,284 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTable - Activate slot AllocationID{eeafe7c5cdc21abeca695c1110bb0bab}.
14:14:56,287 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) switched from SCHEDULED to DEPLOYING.
14:14:56,287 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (1/6) (attempt #0) to 127.0.0.1
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) switched from SCHEDULED to DEPLOYING.
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (2/6) (attempt #0) to 127.0.0.1
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) switched from SCHEDULED to DEPLOYING.
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (3/6) (attempt #0) to 127.0.0.1
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) switched from SCHEDULED to DEPLOYING.
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (5/6) (attempt #0) to 127.0.0.1
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) switched from SCHEDULED to DEPLOYING.
14:14:56,301 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (4/6) (attempt #0) to 127.0.0.1
14:14:56,302 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) switched from SCHEDULED to DEPLOYING.
14:14:56,302 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Custom Source (6/6) (attempt #0) to 127.0.0.1
14:14:56,302 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) switched from SCHEDULED to DEPLOYING.
14:14:56,302 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (6/6) (attempt #0) to 127.0.0.1
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) switched from SCHEDULED to DEPLOYING.
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (5/6) (attempt #0) to 127.0.0.1
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) switched from SCHEDULED to DEPLOYING.
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (4/6) (attempt #0) to 127.0.0.1
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) switched from SCHEDULED to DEPLOYING.
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (3/6) (attempt #0) to 127.0.0.1
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) switched from SCHEDULED to DEPLOYING.
14:14:56,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (2/6) (attempt #0) to 127.0.0.1
14:14:56,310 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) switched from SCHEDULED to DEPLOYING.
14:14:56,310 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying KeyedProcess -> Sink: Print to Std. Out (1/6) (attempt #0) to 127.0.0.1
14:14:56,341 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (1/6).
14:14:56,341 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) switched from CREATED to DEPLOYING.
14:14:56,342 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) [DEPLOYING]
14:14:56,343 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (2/6).
14:14:56,343 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) switched from CREATED to DEPLOYING.
14:14:56,344 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) [DEPLOYING]
14:14:56,345 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) [DEPLOYING].
14:14:56,345 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) [DEPLOYING].
14:14:56,346 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (3/6).
14:14:56,346 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) [DEPLOYING].
14:14:56,346 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) switched from CREATED to DEPLOYING.
14:14:56,346 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) [DEPLOYING].
14:14:56,346 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) [DEPLOYING]
14:14:56,347 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) [DEPLOYING].
14:14:56,347 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) [DEPLOYING].
14:14:56,348 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (5/6).
14:14:56,348 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) switched from CREATED to DEPLOYING.
14:14:56,348 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) [DEPLOYING]
14:14:56,348 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) [DEPLOYING].
14:14:56,349 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) [DEPLOYING].
14:14:56,349 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (4/6).
14:14:56,350 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) switched from CREATED to DEPLOYING.
14:14:56,350 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) [DEPLOYING]
14:14:56,350 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) [DEPLOYING].
14:14:56,350 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) [DEPLOYING].
14:14:56,351 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: Custom Source (6/6).
14:14:56,351 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) switched from CREATED to DEPLOYING.
14:14:56,351 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) [DEPLOYING]
14:14:56,351 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) [DEPLOYING].
14:14:56,352 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) [DEPLOYING].
14:14:56,358 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (6/6).
14:14:56,358 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) switched from CREATED to DEPLOYING.
14:14:56,358 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) [DEPLOYING]
14:14:56,358 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) [DEPLOYING].
14:14:56,359 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) [DEPLOYING].
14:14:56,359 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (5/6).
14:14:56,360 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) switched from CREATED to DEPLOYING.
14:14:56,360 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) [DEPLOYING]
14:14:56,360 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) [DEPLOYING].
14:14:56,361 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) [DEPLOYING].
14:14:56,361 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (4/6).
14:14:56,361 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) switched from CREATED to DEPLOYING.
14:14:56,362 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) [DEPLOYING]
14:14:56,362 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) [DEPLOYING].
14:14:56,362 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) [DEPLOYING].
14:14:56,362 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (3/6).
14:14:56,363 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) switched from CREATED to DEPLOYING.
14:14:56,363 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) [DEPLOYING]
14:14:56,363 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) [DEPLOYING].
14:14:56,363 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) [DEPLOYING].
14:14:56,363 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (2/6).
14:14:56,364 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) switched from CREATED to DEPLOYING.
14:14:56,364 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) [DEPLOYING]
14:14:56,364 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) [DEPLOYING].
14:14:56,364 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) [DEPLOYING].
14:14:56,365 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task KeyedProcess -> Sink: Print to Std. Out (1/6).
14:14:56,365 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) switched from CREATED to DEPLOYING.
14:14:56,365 INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) [DEPLOYING]
14:14:56,365 INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) [DEPLOYING].
14:14:56,366 INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) [DEPLOYING].
14:14:56,399 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) switched from DEPLOYING to RUNNING.
14:14:56,400 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) switched from DEPLOYING to RUNNING.
14:14:56,400 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) switched from DEPLOYING to RUNNING.
14:14:56,401 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (4/6) (d5803a268c85b9252c3dd4832f0efb91) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (5/6) (e03a027bce2ba19522fab001d87030a9) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (6/6) (6cdfffa3abb64a4c793e121380fbc75a) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (2/6) (54e4eb28f5db162e18f78c47bbfba0b2) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (3/6) (f283227159252e6e8ec6b649e143a0b3) switched from DEPLOYING to RUNNING.
14:14:56,402 INFO org.apache.flink.runtime.taskmanager.Task - KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) switched from DEPLOYING to RUNNING.
14:14:56,403 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - KeyedProcess -> Sink: Print to Std. Out (1/6) (b6791c604d7fd202dbfa4249a45b929d) switched from DEPLOYING to RUNNING.
14:14:56,414 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)
14:14:56,415 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)
14:14:56,415 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)
14:14:56,415 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)
14:14:56,415 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)
14:14:56,415 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)
14:14:56,444 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) switched from DEPLOYING to RUNNING.
14:14:56,444 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)
14:14:56,444 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (2/6) (e0d9003512d69f3d09335aa20d622fbf) switched from DEPLOYING to RUNNING.
14:14:56,445 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) switched from DEPLOYING to RUNNING.
14:14:56,444 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) switched from DEPLOYING to RUNNING.
14:14:56,445 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) switched from DEPLOYING to RUNNING.
14:14:56,447 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) switched from DEPLOYING to RUNNING.
14:14:56,447 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)
14:14:56,447 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)
14:14:56,447 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)
14:14:56,448 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (5/6) (e0deef4429bf5e52640f72f842637cd0) switched from DEPLOYING to RUNNING.
14:14:56,448 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)
14:14:56,448 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (3/6) (8ca447cc1791c742205ab750b9e246b7) switched from DEPLOYING to RUNNING.
14:14:56,448 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (1/6) (038cfcd732466cc839e590c3f9cd52ab) switched from DEPLOYING to RUNNING.
14:14:56,448 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (6/6) (ffbcaedfd164e52b4e775bd29a3f639f) switched from DEPLOYING to RUNNING.
14:14:56,450 INFO org.apache.flink.runtime.taskmanager.Task - Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) switched from DEPLOYING to RUNNING.
14:14:56,450 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)
14:14:56,453 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Custom Source (4/6) (46497f932624a3cf456fd66e6059a1ce) switched from DEPLOYING to RUNNING.
14:14:56,543 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
14:14:56,543 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
14:14:56,543 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
14:14:56,544 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
14:14:56,544 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
14:14:56,544 INFO org.apache.flink.runtime.state.heap.HeapKeyedStateBackend - Initializing heap keyed state backend with stream factory.
2> Temperature of sensor 'sensor_53' monotonically increased for 1 second.
1> Temperature of sensor 'sensor_24' monotonically increased for 1 second.
5> Temperature of sensor 'sensor_50' monotonically increased for 1 second.
6> Temperature of sensor 'sensor_9' monotonically increased for 1 second.
5> Temperature of sensor 'sensor_52' monotonically increased for 1 second.
3> Temperature of sensor 'sensor_12' monotonically increased for 1 second.
5> Temperature of sensor 'sensor_4' monotonically increased for 1 second.
6> Temperature of sensor 'sensor_45' monotonically increased for 1 second.
1> Temperature of sensor 'sensor_13' monotonically increased for 1 second.
1> Temperature of sensor 'sensor_13' monotonically increased for 1 second.
3> Temperature of sensor 'sensor_20' monotonically increased for 1 second.
14:15:54,194 INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
14:15:54,194 INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
14:15:54,195 INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
14:15:54,251 INFO org.apache.flink.runtime.io.disk.iomanager.IOManager - I/O manager removed spill file directory C:\Users\weitong\AppData\Local\Temp\flink-io-ee514c39-9efc-4dfd-8a83-232c5ca0d86a
14:15:54,252 INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:51094
Process finished with exit code 1
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment