OSDir

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

YARN per-job cluster reserves all of remaining memory in YARN


I'm testing per-job cluster on YARN.

I just need to launch 7 TMs each with 50GB memory (total 350GB) but Flink makes more resource request to YARN than necessary.

All of the remaining memory in YARN, around 370GB, are reserved by the Flink job, which I can check in YARN UI.

The remaining memory is not used but reserved; that’s very weird.

Attached is JM log.

Any help would be greatly appreciated!

Thanks,

- Dongwon

2018-05-05 04:33:35,749 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - --------------------------------------------------------------------------------
2018-05-05 04:33:35,750 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Starting YarnJobClusterEntrypoint (Version: 1.6-SNAPSHOT, Rev:d519eb7, Date:22.04.2018 @ 14:28:36 UTC)
2018-05-05 04:33:35,750 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  OS current user: root
2018-05-05 04:33:36,080 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Current Hadoop/Kerberos user: root
2018-05-05 04:33:36,080 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.161-b14
2018-05-05 04:33:36,080 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Maximum heap size: 6827 MiBytes
2018-05-05 04:33:36,080 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  JAVA_HOME: /usr/lib/jvm/java-1.8.0-openjdk
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Hadoop version: 2.4.1
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  JVM Options:
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -     -Xmx7680m
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -     -Dlog.file=/opt/hadoop/logs/userlogs/application_1523253511658_0065/container_1523253511658_0065_01_000001/jobmanager.log
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -     -Dlogback.configurationFile=file:logback.xml
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -     -Dlog4j.configuration=file:log4j.properties
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Program Arguments: (none)
2018-05-05 04:33:36,081 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         -  Classpath: Tmap-1.0-SNAPSHOT.jar:lib/flink-dist_2.11-1.6-SNAPSHOT.jar:lib/flink-metrics-prometheus-1.6-SNAPSHOT.jar:lib/flink-python_2.11-1.6-SNAPSHOT.jar:lib/flink-queryable-state-runtime_2.11-1.6-SNAPSHOT.jar:lib/flink-shaded-hadoop2-uber-1.6-SNAPSHOT.jar:lib/log4j-1.2.17.jar:lib/slf4j-log4j12-1.7.7.jar:log4j.properties:logback.xml:flink.jar:flink-conf.yaml:job.graph::/opt/hadoop/etc/hadoop:/opt/hadoop/share/hadoop/common/hadoop-common-2.8.3-tests.jar:/opt/hadoop/share/hadoop/common/hadoop-common-2.8.3.jar:/opt/hadoop/share/hadoop/common/hadoop-nfs-2.8.3.jar:/opt/hadoop/share/hadoop/common/lib/activation-1.1.jar:/opt/hadoop/share/hadoop/common/lib/apacheds-i18n-2.0.0-M15.jar:/opt/hadoop/share/hadoop/common/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/opt/hadoop/share/hadoop/common/lib/api-asn1-api-1.0.0-M20.jar:/opt/hadoop/share/hadoop/common/lib/api-util-1.0.0-M20.jar:/opt/hadoop/share/hadoop/common/lib/asm-3.2.jar:/opt/hadoop/share/hadoop/common/lib/avro-1.7.4.jar:/opt/hadoop/share/hadoop/common/lib/commons-beanutils-1.7.0.jar:/opt/hadoop/share/hadoop/common/lib/commons-beanutils-core-1.8.0.jar:/opt/hadoop/share/hadoop/common/lib/commons-cli-1.2.jar:/opt/hadoop/share/hadoop/common/lib/commons-codec-1.4.jar:/opt/hadoop/share/hadoop/common/lib/commons-collections-3.2.2.jar:/opt/hadoop/share/hadoop/common/lib/commons-compress-1.4.1.jar:/opt/hadoop/share/hadoop/common/lib/commons-configuration-1.6.jar:/opt/hadoop/share/hadoop/common/lib/commons-digester-1.8.jar:/opt/hadoop/share/hadoop/common/lib/commons-io-2.4.jar:/opt/hadoop/share/hadoop/common/lib/commons-lang-2.6.jar:/opt/hadoop/share/hadoop/common/lib/commons-logging-1.1.3.jar:/opt/hadoop/share/hadoop/common/lib/commons-math3-3.1.1.jar:/opt/hadoop/share/hadoop/common/lib/commons-net-3.1.jar:/opt/hadoop/share/hadoop/common/lib/curator-client-2.7.1.jar:/opt/hadoop/share/hadoop/common/lib/curator-framework-2.7.1.jar:/opt/hadoop/share/hadoop/common/lib/curator-recipes-2.7.1.jar:/opt/hadoop/share/hadoop/common/lib/gson-2.2.4.jar:/opt/hadoop/share/hadoop/common/lib/guava-11.0.2.jar:/opt/hadoop/share/hadoop/common/lib/hadoop-annotations-2.8.3.jar:/opt/hadoop/share/hadoop/common/lib/hadoop-auth-2.8.3.jar:/opt/hadoop/share/hadoop/common/lib/hamcrest-core-1.3.jar:/opt/hadoop/share/hadoop/common/lib/htrace-core4-4.0.1-incubating.jar:/opt/hadoop/share/hadoop/common/lib/httpclient-4.5.2.jar:/opt/hadoop/share/hadoop/common/lib/httpcore-4.4.4.jar:/opt/hadoop/share/hadoop/common/lib/jackson-core-asl-1.9.13.jar:/opt/hadoop/share/hadoop/common/lib/jackson-jaxrs-1.9.13.jar:/opt/hadoop/share/hadoop/common/lib/jackson-mapper-asl-1.9.13.jar:/opt/hadoop/share/hadoop/common/lib/jackson-xc-1.9.13.jar:/opt/hadoop/share/hadoop/common/lib/java-xmlbuilder-0.4.jar:/opt/hadoop/share/hadoop/common/lib/jaxb-api-2.2.2.jar:/opt/hadoop/share/hadoop/common/lib/jaxb-impl-2.2.3-1.jar:/opt/hadoop/share/hadoop/common/lib/jcip-annotations-1.0.jar:/opt/hadoop/share/hadoop/common/lib/jersey-core-1.9.jar:/opt/hadoop/share/hadoop/common/lib/jersey-json-1.9.jar:/opt/hadoop/share/hadoop/common/lib/jersey-server-1.9.jar:/opt/hadoop/share/hadoop/common/lib/jets3t-0.9.0.jar:/opt/hadoop/share/hadoop/common/lib/jettison-1.1.jar:/opt/hadoop/share/hadoop/common/lib/jetty-6.1.26.jar:/opt/hadoop/share/hadoop/common/lib/jetty-sslengine-6.1.26.jar:/opt/hadoop/share/hadoop/common/lib/jetty-util-6.1.26.jar:/opt/hadoop/share/hadoop/common/lib/jsch-0.1.54.jar:/opt/hadoop/share/hadoop/common/lib/json-smart-1.1.1.jar:/opt/hadoop/share/hadoop/common/lib/jsp-api-2.1.jar:/opt/hadoop/share/hadoop/common/lib/jsr305-3.0.0.jar:/opt/hadoop/share/hadoop/common/lib/junit-4.11.jar:/opt/hadoop/share/hadoop/common/lib/log4j-1.2.17.jar:/opt/hadoop/share/hadoop/common/lib/mockito-all-1.8.5.jar:/opt/hadoop/share/hadoop/common/lib/netty-3.6.2.Final.jar:/opt/hadoop/share/hadoop/common/lib/nimbus-jose-jwt-3.9.jar:/opt/hadoop/share/hadoop/common/lib/paranamer-2.3.jar:/opt/hadoop/share/hadoop/common/lib/protobuf-java-2.5.0.jar:/opt/hadoop/share/hadoop/common/lib/servlet-api-2.5.jar:/opt/hadoop/share/hadoop/common/lib/slf4j-api-1.7.10.jar:/opt/hadoop/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar:/opt/hadoop/share/hadoop/common/lib/snappy-java-1.0.4.1.jar:/opt/hadoop/share/hadoop/common/lib/stax-api-1.0-2.jar:/opt/hadoop/share/hadoop/common/lib/xmlenc-0.52.jar:/opt/hadoop/share/hadoop/common/lib/xz-1.0.jar:/opt/hadoop/share/hadoop/common/lib/zookeeper-3.4.6.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-2.8.3-tests.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-2.8.3.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-client-2.8.3-tests.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-client-2.8.3.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-native-client-2.8.3-tests.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-native-client-2.8.3.jar:/opt/hadoop/share/hadoop/hdfs/hadoop-hdfs-nfs-2.8.3.jar:/opt/hadoop/share/hadoop/hdfs/lib/asm-3.2.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-cli-1.2.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-codec-1.4.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-daemon-1.0.13.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-io-2.4.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-lang-2.6.jar:/opt/hadoop/share/hadoop/hdfs/lib/commons-logging-1.1.3.jar:/opt/hadoop/share/hadoop/hdfs/lib/guava-11.0.2.jar:/opt/hadoop/share/hadoop/hdfs/lib/hadoop-hdfs-client-2.8.3.jar:/opt/hadoop/share/hadoop/hdfs/lib/htrace-core4-4.0.1-incubating.jar:/opt/hadoop/share/hadoop/hdfs/lib/jackson-core-asl-1.9.13.jar:/opt/hadoop/share/hadoop/hdfs/lib/jackson-mapper-asl-1.9.13.jar:/opt/hadoop/share/hadoop/hdfs/lib/jersey-core-1.9.jar:/opt/hadoop/share/hadoop/hdfs/lib/jersey-server-1.9.jar:/opt/hadoop/share/hadoop/hdfs/lib/jetty-6.1.26.jar:/opt/hadoop/share/hadoop/hdfs/lib/jetty-util-6.1.26.jar:/opt/hadoop/share/hadoop/hdfs/lib/jsr305-3.0.0.jar:/opt/hadoop/share/hadoop/hdfs/lib/leveldbjni-all-1.8.jar:/opt/hadoop/share/hadoop/hdfs/lib/log4j-1.2.17.jar:/opt/hadoop/share/hadoop/hdfs/lib/netty-3.6.2.Final.jar:/opt/hadoop/share/hadoop/hdfs/lib/netty-all-4.0.23.Final.jar:/opt/hadoop/share/hadoop/hdfs/lib/okhttp-2.4.0.jar:/opt/hadoop/share/hadoop/hdfs/lib/okio-1.4.0.jar:/opt/hadoop/share/hadoop/hdfs/lib/protobuf-java-2.5.0.jar:/opt/hadoop/share/hadoop/hdfs/lib/servlet-api-2.5.jar:/opt/hadoop/share/hadoop/hdfs/lib/xercesImpl-2.9.1.jar:/opt/hadoop/share/hadoop/hdfs/lib/xml-apis-1.3.04.jar:/opt/hadoop/share/hadoop/hdfs/lib/xmlenc-0.52.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-api-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-applications-distributedshell-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-client-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-common-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-registry-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-applicationhistoryservice-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-common-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-nodemanager-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-resourcemanager-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-sharedcachemanager-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-tests-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-timeline-pluginstorage-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/hadoop-yarn-server-web-proxy-2.8.3.jar:/opt/hadoop/share/hadoop/yarn/lib/activation-1.1.jar:/opt/hadoop/share/hadoop/yarn/lib/aopalliance-1.0.jar:/opt/hadoop/share/hadoop/yarn/lib/asm-3.2.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-cli-1.2.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-codec-1.4.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-collections-3.2.2.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-compress-1.4.1.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-io-2.4.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-lang-2.6.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-logging-1.1.3.jar:/opt/hadoop/share/hadoop/yarn/lib/commons-math-2.2.jar:/opt/hadoop/share/hadoop/yarn/lib/curator-client-2.7.1.jar:/opt/hadoop/share/hadoop/yarn/lib/curator-test-2.7.1.jar:/opt/hadoop/share/hadoop/yarn/lib/fst-2.50.jar:/opt/hadoop/share/hadoop/yarn/lib/guava-11.0.2.jar:/opt/hadoop/share/hadoop/yarn/lib/guice-3.0.jar:/opt/hadoop/share/hadoop/yarn/lib/guice-servlet-3.0.jar:/opt/hadoop/share/hadoop/yarn/lib/jackson-core-asl-1.9.13.jar:/opt/hadoop/share/hadoop/yarn/lib/jackson-jaxrs-1.9.13.jar:/opt/hadoop/share/hadoop/yarn/lib/jackson-mapper-asl-1.9.13.jar:/opt/hadoop/share/hadoop/yarn/lib/jackson-xc-1.9.13.jar:/opt/hadoop/share/hadoop/yarn/lib/java-util-1.9.0.jar:/opt/hadoop/share/hadoop/yarn/lib/javassist-3.18.1-GA.jar:/opt/hadoop/share/hadoop/yarn/lib/javax.inject-1.jar:/opt/hadoop/share/hadoop/yarn/lib/jaxb-api-2.2.2.jar:/opt/hadoop/share/hadoop/yarn/lib/jaxb-impl-2.2.3-1.jar:/opt/hadoop/share/hadoop/yarn/lib/jersey-client-1.9.jar:/opt/hadoop/share/hadoop/yarn/lib/jersey-core-1.9.jar:/opt/hadoop/share/hadoop/yarn/lib/jersey-guice-1.9.jar:/opt/hadoop/share/hadoop/yarn/lib/jersey-json-1.9.jar:/opt/hadoop/share/hadoop/yarn/lib/jersey-server-1.9.jar:/opt/hadoop/share/hadoop/yarn/lib/jettison-1.1.jar:/opt/hadoop/share/hadoop/yarn/lib/jetty-6.1.26.jar:/opt/hadoop/share/hadoop/yarn/lib/jetty-util-6.1.26.jar:/opt/hadoop/share/hadoop/yarn/lib/json-io-2.5.1.jar:/opt/hadoop/share/hadoop/yarn/lib/jsr305-3.0.0.jar:/opt/hadoop/share/hadoop/yarn/lib/leveldbjni-all-1.8.jar:/opt/hadoop/share/hadoop/yarn/lib/log4j-1.2.17.jar:/opt/hadoop/share/hadoop/yarn/lib/netty-3.6.2.Final.jar:/opt/hadoop/share/hadoop/yarn/lib/protobuf-java-2.5.0.jar:/opt/hadoop/share/hadoop/yarn/lib/servlet-api-2.5.jar:/opt/hadoop/share/hadoop/yarn/lib/stax-api-1.0-2.jar:/opt/hadoop/share/hadoop/yarn/lib/xz-1.0.jar:/opt/hadoop/share/hadoop/yarn/lib/zookeeper-3.4.6-tests.jar:/opt/hadoop/share/hadoop/yarn/lib/zookeeper-3.4.6.jar
2018-05-05 04:33:36,082 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - --------------------------------------------------------------------------------
2018-05-05 04:33:36,082 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Registered UNIX signal handlers for [TERM, HUP, INT]
2018-05-05 04:33:36,085 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - YARN daemon is running as: root Yarn client user obtainer: root
2018-05-05 04:33:36,086 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: blob.server.port, 20324
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: metrics.reporter.prom.port, 20251-20252
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: high-availability.cluster-id, application_1523253511658_0065
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: jobmanager.heap.mb, 10240
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: state.savepoints.dir, hdfs://dacoe1:20400/flink-savepoint
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: io.tmp.dirs, /local1/flink-taskmanager,/local2/flink-taskmanager
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: internal.cluster.execution-mode, DETACHED
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: parallelism.default, 1
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.numberOfTaskSlots, 16
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: metrics.reporters, prom
2018-05-05 04:33:36,087 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: taskmanager.heap.mb, 51200
2018-05-05 04:33:36,088 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: metrics.reporter.prom.class, org.apache.flink.metrics.prometheus.PrometheusReporter
2018-05-05 04:33:36,088 INFO  org.apache.flink.configuration.GlobalConfiguration            - Loading configuration property: yarn.application-master.port, 20326-20329
2018-05-05 04:33:36,097 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Overriding YARN's temporary file directories with those specified in the Flink config: /local1/flink-taskmanager,/local2/flink-taskmanager
2018-05-05 04:33:36,109 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Starting YarnJobClusterEntrypoint.
2018-05-05 04:33:36,109 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Install default filesystem.
2018-05-05 04:33:36,152 INFO  org.apache.flink.runtime.security.modules.HadoopModule        - Hadoop user set to root (auth:SIMPLE)
2018-05-05 04:33:36,164 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Initializing cluster services.
2018-05-05 04:33:36,168 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Trying to start actor system at dacoe5.weave.local:20326
2018-05-05 04:33:36,654 INFO  akka.event.slf4j.Slf4jLogger                                  - Slf4jLogger started
2018-05-05 04:33:36,762 INFO  akka.remote.Remoting                                          - Starting remoting
2018-05-05 04:33:36,890 INFO  akka.remote.Remoting                                          - Remoting started; listening on addresses :[akka.tcp://flink@dacoe5.weave.local:20326]
2018-05-05 04:33:36,901 INFO  org.apache.flink.runtime.entrypoint.ClusterEntrypoint         - Actor system started at akka.tcp://flink@dacoe5.weave.local:20326
2018-05-05 04:33:36,928 INFO  org.apache.flink.runtime.blob.BlobServer                      - Created BLOB server storage directory /local2/flink-taskmanager/blobStore-e3769431-6c0c-42b1-9fe0-ad53fa1048a3
2018-05-05 04:33:36,933 INFO  org.apache.flink.runtime.blob.BlobServer                      - Started BLOB server at 0.0.0.0:20324 - max concurrent requests: 50 - max backlog: 1000
2018-05-05 04:33:36,966 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl           - Configuring prom with {port=20251-20252, class=org.apache.flink.metrics.prometheus.PrometheusReporter}.
2018-05-05 04:33:36,971 INFO  org.apache.flink.metrics.prometheus.PrometheusReporter        - Started PrometheusReporter HTTP server on port 20251.
2018-05-05 04:33:36,972 INFO  org.apache.flink.runtime.metrics.MetricRegistryImpl           - Reporting metrics for reporter prom of type org.apache.flink.metrics.prometheus.PrometheusReporter.
2018-05-05 04:33:36,980 INFO  org.apache.flink.runtime.blob.TransientBlobCache              - Created BLOB cache storage directory /local2/flink-taskmanager/blobStore-fc21519e-04cb-48ff-a555-2f72c3c08361
2018-05-05 04:33:36,989 WARN  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Upload directory /tmp/flink-web-72c60afa-6237-4cf5-b9d0-70f329c2031d/flink-web-upload does not exist, or has been deleted externally. Previously uploaded files are no longer available.
2018-05-05 04:33:36,990 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Created directory /tmp/flink-web-72c60afa-6237-4cf5-b9d0-70f329c2031d/flink-web-upload for file uploads.
2018-05-05 04:33:37,009 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Starting rest endpoint.
2018-05-05 04:33:37,286 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils           - Determined location of main cluster component log file: /opt/hadoop/logs/userlogs/application_1523253511658_0065/container_1523253511658_0065_01_000001/jobmanager.log
2018-05-05 04:33:37,286 INFO  org.apache.flink.runtime.webmonitor.WebMonitorUtils           - Determined location of main cluster component stdout file: /opt/hadoop/logs/userlogs/application_1523253511658_0065/container_1523253511658_0065_01_000001/jobmanager.out
2018-05-05 04:33:37,359 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Rest endpoint listening at dacoe5.weave.local:40105
2018-05-05 04:33:37,359 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - http://dacoe5.weave.local:40105 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000
2018-05-05 04:33:37,359 INFO  org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint  - Web frontend listening at http://dacoe5.weave.local:40105.
2018-05-05 04:33:37,369 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.yarn.YarnResourceManager at akka://flink/user/resourcemanager .
2018-05-05 04:33:37,489 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.MiniDispatcher at akka://flink/user/dispatcher .
2018-05-05 04:33:37,503 INFO  org.apache.flink.yarn.YarnResourceManager                     - ResourceManager akka.tcp://flink@dacoe5.weave.local:20326/user/resourcemanager was granted leadership with fencing token 00000000000000000000000000000000
2018-05-05 04:33:37,504 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Starting the SlotManager.
2018-05-05 04:33:37,519 INFO  org.apache.hadoop.yarn.client.RMProxy                         - Connecting to ResourceManager at dacoe1/10.44.0.0:20263
2018-05-05 04:33:37,742 INFO  org.apache.flink.yarn.YarnResourceManager                     - Recovered 0 containers from previous attempts ([]).
2018-05-05 04:33:37,745 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - yarn.client.max-nodemanagers-proxies : 500
2018-05-05 04:33:37,757 INFO  org.apache.flink.runtime.dispatcher.MiniDispatcher            - Dispatcher akka.tcp://flink@dacoe5.weave.local:20326/user/dispatcher was granted leadership with fencing token 00000000000000000000000000000000
2018-05-05 04:33:37,757 INFO  org.apache.flink.runtime.dispatcher.MiniDispatcher            - Recovering all persisted jobs.
2018-05-05 04:33:37,774 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_0 .
2018-05-05 04:33:37,785 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Initializing job  (18d36ace3769df9f8bfcb20cbf1e4241).
2018-05-05 04:33:37,796 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Using restart strategy FixedDelayRestartStrategy(maxNumberRestartAttempts=2147483647, delayBetweenRestartAttempts=0) for  (18d36ace3769df9f8bfcb20cbf1e4241).
2018-05-05 04:33:37,801 INFO  org.apache.flink.runtime.rpc.akka.AkkaRpcService              - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/8b6ef169-8fd1-4b0e-93b0-ad73d1945582 .
2018-05-05 04:33:37,823 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job recovers via failover strategy: full graph restart
2018-05-05 04:33:37,851 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Running initialization on master for job  (18d36ace3769df9f8bfcb20cbf1e4241).
2018-05-05 04:33:37,851 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Successfully ran initialization on master in 0 ms.
2018-05-05 04:33:37,881 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Using application-defined state backend: File State Backend (checkpoints: 'hdfs://dacoe1:20400/flink-ckpt', savepoints: 'null', asynchronous: UNDEFINED, fileStateThreshold: -1)
2018-05-05 04:33:37,881 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Configuring application-defined state backend with job/cluster config
2018-05-05 04:33:38,177 INFO  org.apache.flink.runtime.jobmaster.JobManagerRunner           - JobManager runner for job  (18d36ace3769df9f8bfcb20cbf1e4241) was granted leadership with session id 00000000-0000-0000-0000-000000000000 at akka.tcp://flink@dacoe5.weave.local:20326/user/jobmanager_0.
2018-05-05 04:33:38,178 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Starting execution of job  (18d36ace3769df9f8bfcb20cbf1e4241)
2018-05-05 04:33:38,180 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Job  (18d36ace3769df9f8bfcb20cbf1e4241) switched from state CREATED to RUNNING.
2018-05-05 04:33:38,183 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (1/7) (6605d6809e7379a3906d738019e5d8c3) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,188 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (2/7) (3203f012de92bf645c062325bff008e4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,188 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (3/7) (04f8efd2a0c404c5f90e98bde4b7da43) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,189 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (4/7) (fd8110f559e683a4b64b056146eeaa87) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,189 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (5/7) (4bf1bce78d3fa71fbb421268031c8a93) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,189 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (6/7) (08019b5d8369db913acb716cefb38e8d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,189 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (7/7) (0094a247da975e97a6626c4864971dda) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,189 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (f95355491ac9afbfa46444ba096abf93) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,190 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Print to Std. Err (1/1) (be02ec197cfc583b6691ef4b2718fe83) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,190 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (1/100) (56ac25d5ed290f109b3c75123317431f) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,190 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (2/100) (c36f9b5eaeb9ae431b7addc9e2eb69a6) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (3/100) (f47ae87a4b993d178223b624d35ffc42) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (4/100) (86a6914c53718d615ebac3d677ea63d1) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (5/100) (319d2ae3c6ba7a0a1b15a2180c5c8a66) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (6/100) (a78f13b0e4027591f1476e280d384dc7) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (7/100) (3574bc05c74a68876da583c69b0ec1f1) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (8/100) (91217e9cac8ee010e0f749b890954390) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (9/100) (e8a90910efd88c68d7230e479e5a5a88) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (10/100) (74d95462166e0f5c1ee9f3c172446c6f) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,191 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (11/100) (86cb2d7546011acd2f84ecf4cc443f10) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (12/100) (46cb4d918ff0df31c134c9ba64e54ae9) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (13/100) (211e02e45ffbca123e175367b5a5ddad) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (14/100) (2b5f68fc2efa948c48d3795d06410cc4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (15/100) (a382314f537ea1d3f6ee8d789d5477c6) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (16/100) (07aefbb36b6dadab84dc90a2960bdb04) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (17/100) (2c863ee662f4caee3a1d8f41a7bc71ff) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,192 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (18/100) (2586c1068e6cb20aebfa0dc41f9a29ef) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,193 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (19/100) (c99aa01aa6095f800db0851a67f0a43d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,193 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (20/100) (1c0cea88b36f02668525ef39bb8a0909) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,193 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (21/100) (e869c79f2a863ae68b6b639c0f2da9a5) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,193 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (22/100) (6e0b300b7829a8bdb8aac3bdce607317) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,193 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (23/100) (0e5436624a86c9bdfb4c779fc3d1309b) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (24/100) (8edcdf9bb84c284ba2683a49691a9e1f) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (25/100) (a7108b9634fed9e1d3d2f63fe4c54ac6) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (26/100) (3f00ed8ef2114d8dbe5bb21330b34b66) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (27/100) (fb6f94aae5956a7199098cd33e5fbd09) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,194 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (28/100) (7150047330a3fe41086cca96719c1770) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (29/100) (a1445d5308d37bc8d354f0f475b54f8b) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (30/100) (29d6951a99580963e87df38b442aca02) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (31/100) (f5703f7e89a6df849706707c2f611daf) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (32/100) (0752e696f8b6f73083c0fceae6faa622) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (33/100) (7112f35ec539088255b28181b6bfe61c) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (34/100) (68572637ec60d9264c4fa6edb441ba14) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (35/100) (eade9f64a219dadef24b52612a9f5ab5) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (36/100) (5d0f778e86c11a01e808320f571a2f5e) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (37/100) (158fe84207be7bf750ff59b1746170a0) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (38/100) (d6ac046d89974dbec7adef0525bf9ac4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (39/100) (cc8a00e673542268dbdbe64a8e93b043) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (40/100) (c56f0ce39454019b074dcec8c5c04c4b) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (41/100) (ff96ba82a6e6e60fb533af48dffa8541) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (42/100) (165ef743e3498c1470e6f2967f229f3a) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (43/100) (4eca9489afdc900990c96402b0108e80) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (44/100) (c19c601e7cb0dce6ba573be2e37e4a13) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (45/100) (a78cccaac1c36ab36cbe3c11f9f9ee25) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (46/100) (5a5c2a42e8824d0f578bdc69ae09ae9d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (47/100) (73c36ed7a27511aaa344874f22eb9995) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (48/100) (d1858ec3d0226eca79f5e624019b29dc) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (49/100) (2c236541a48d41ca0e163dd45906a975) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (50/100) (5bf42cf222e2dd971642db4a699e6416) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (51/100) (5ea488596d34a93234af8ff79fa7a9aa) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (52/100) (ad5e1a5d9c570e3009593e5442fda0d0) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (53/100) (7a19aecf023fb73dbe4d7656ce29e959) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (54/100) (f8ddf2d9c97d1e94b59921fc71ff0ecd) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (55/100) (efecbd93dda16c89a0b041c7061ecae7) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (56/100) (6820e874e9baa5ffb160b93a8a161815) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (57/100) (7cfeb7da03322af2c4a22b6365f913f9) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (58/100) (fa38d38248ad84ef5fd4e749cca8b1ea) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (59/100) (aaabcf1255ca85971941e482fd2c3d74) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (60/100) (fb124290edd0b5208cedcfa1a3c8acd4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (61/100) (d8f372eba8b210d34f1126c046bfc37d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (62/100) (848e8a72bef5198f65c765fb7de10495) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (63/100) (62c4615a4a623245b3c743f2af567578) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (64/100) (ba41d639728e4e7a6635fe4f2f573034) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (65/100) (ad6cb68d059cf0c8e7e7b635eba9c60c) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (66/100) (b0d53734eed3795c149edcd63f2071f6) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (67/100) (342dfcf4d5d7c47a671cafe124791b1d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (68/100) (320cb4f5f2b418f5a514c60ac34b275f) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (69/100) (e0f53d43cbfa66b71c55ab8d3ced1dcf) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (70/100) (ce715d4f25a0d53fdcb88ea4b27c1934) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,198 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (71/100) (43370e6ae071a21e7aa9fc13b86f0a89) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (72/100) (ed9f544feb284f79ce5dab9dcf5fcb7b) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (73/100) (75efa599af96228ad3ff5c8e04f400ee) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (74/100) (ce37e4489767f21f4972c22e930fcd78) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (75/100) (c5c6e6435d67451ae67480542ebc53e4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (76/100) (a6778dcde150c0ef142e37d0bb6c09b1) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (77/100) (685872161d99e829d98fa2ff4286d991) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (78/100) (567017acafc028e549fec23c626815ea) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (79/100) (d59fb9051cfb3b5424311868e3383b58) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (80/100) (5ce69ef79e6cd03e773ff769c34c8329) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (81/100) (94880940c9278f7a1449dca8d7f645df) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (82/100) (ffd5a700d7a766774b32dd9412ec2db2) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,199 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (83/100) (8ba09f39b39526b7f156241a97b7390c) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (84/100) (d99329571fef744ef93a7b330fcd8d0b) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (85/100) (26f4b5a28cf30467f29beb5517451802) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (86/100) (3b9aa5cd305c2bbfa25c66ff2f4803f8) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (87/100) (e4079569f5dbbd28822d87325eb4f927) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (88/100) (17fb3272bcd93808600557f18c95307e) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (89/100) (14f4a5c321dc46d785b034c9ab525620) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (90/100) (62698b99c3378da5c911b544fed63be3) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (91/100) (ebb37c1c89cec891a5e6a97622fe5bd2) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (92/100) (19f623d300123a530a1a2670fb0d2aac) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (93/100) (1e7fec292a896ab3cdffa2cf5e033a62) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (94/100) (6c6733eea687350fea04232e270a2c9d) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,200 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (95/100) (b66617d90ce126d95ba876af4c5b7535) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (96/100) (a436caffb7c42e1753d68375c24cecbb) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (97/100) (d8f27f5e140097e2b8e3a32e3b6d32f0) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (98/100) (d234de5497675ee73ed20f8249d9e14c) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (99/100) (9e0611294f12c9e958a35ea501398d78) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (100/100) (63cd5980b9b45a3c0dce0fcafc039bd4) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,201 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (e96c5db22f9da512626201c7583ea1f0) switched from CREATED to SCHEDULED.
2018-05-05 04:33:38,202 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request 4129e730c7d18594fcbffcbf822f1771
2018-05-05 04:33:38,203 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Attempting to register at ResourceManager akka.tcp://flink@dacoe5.weave.local:20326/user/resourcemanager
2018-05-05 04:33:38,206 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Resolved ResourceManager address, beginning registration
2018-05-05 04:33:38,206 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - Registration at ResourceManager attempt 1 (timeout=100ms)
2018-05-05 04:33:38,207 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request 6835498f1871acee1eb1adba7c36710a
2018-05-05 04:33:38,208 INFO  org.apache.flink.yarn.YarnResourceManager                     - Registering job manager 00000000000000000000000000000000@xxxxxxxx://flink@dacoe5.weave.local:20326/user/jobmanager_0 for job 18d36ace3769df9f8bfcb20cbf1e4241.
2018-05-05 04:33:38,208 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request fcc6e3540281ce0b621dbde08b9e8507
2018-05-05 04:33:38,208 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request ef2682c38dc9357f621a39f23d65ac8b
2018-05-05 04:33:38,208 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request 220f03f89792c64ee970591258bd3d24
2018-05-05 04:33:38,208 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request a9a661ed77b662911c8de5ea2221f395
2018-05-05 04:33:38,209 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Cannot serve slot request, no ResourceManager connected. Adding as pending request 94052f032e8a39f833caab2710662653
2018-05-05 04:33:38,214 INFO  org.apache.flink.yarn.YarnResourceManager                     - Registered job manager 00000000000000000000000000000000@xxxxxxxx://flink@dacoe5.weave.local:20326/user/jobmanager_0 for job 18d36ace3769df9f8bfcb20cbf1e4241.
2018-05-05 04:33:38,217 INFO  org.apache.flink.runtime.jobmaster.JobMaster                  - JobManager successfully registered at ResourceManager, leader id: 00000000000000000000000000000000.
2018-05-05 04:33:38,218 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 220f03f89792c64ee970591258bd3d24).
2018-05-05 04:33:38,219 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id c5951802c0c3e3c8e33d049879643a1a.
2018-05-05 04:33:38,220 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 4129e730c7d18594fcbffcbf822f1771).
2018-05-05 04:33:38,220 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6835498f1871acee1eb1adba7c36710a).
2018-05-05 04:33:38,220 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = ef2682c38dc9357f621a39f23d65ac8b).
2018-05-05 04:33:38,220 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = fcc6e3540281ce0b621dbde08b9e8507).
2018-05-05 04:33:38,221 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 94052f032e8a39f833caab2710662653).
2018-05-05 04:33:38,221 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a9a661ed77b662911c8de5ea2221f395).
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 1.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id acdd834e52450d7dec9f4589e5fa662f.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 2.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 9d1f6a21c083bbf13cbfdebb01fbef13.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 3.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 296901d97accd2dc95a5b788a966f913.
2018-05-05 04:33:38,226 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 4.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 79b278c9d3a3a7ba1560c61e9377dd3d.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 5.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 2856dff18a56d49bb3424bb0b06fea57.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 6.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 39ff8acef08ee43766a61105bb52c112.
2018-05-05 04:33:38,227 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 7.
2018-05-05 04:33:43,295 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe5.weave.local:20265
2018-05-05 04:33:43,303 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000002 - Remaining pending container requests: 7
2018-05-05 04:33:43,546 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:43,547 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:43,558 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe5.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe8.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe2.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe3.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe6.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe4.weave.local:20265
2018-05-05 04:33:43,799 INFO  org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl         - Received new token for : dacoe7.weave.local:20265
2018-05-05 04:33:43,800 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000003 - Remaining pending container requests: 6
2018-05-05 04:33:43,854 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:43,855 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:43,856 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe3.weave.local:20265
2018-05-05 04:33:44,144 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000004 - Remaining pending container requests: 5
2018-05-05 04:33:44,201 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:44,202 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:44,203 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe6.weave.local:20265
2018-05-05 04:33:44,495 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000005 - Remaining pending container requests: 4
2018-05-05 04:33:44,545 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:44,545 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:44,547 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe4.weave.local:20265
2018-05-05 04:33:44,861 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000006 - Remaining pending container requests: 3
2018-05-05 04:33:44,906 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:44,907 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:44,909 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe7.weave.local:20265
2018-05-05 04:33:45,242 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000007 - Remaining pending container requests: 2
2018-05-05 04:33:45,289 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:45,289 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:45,290 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe8.weave.local:20265
2018-05-05 04:33:45,619 INFO  org.apache.flink.yarn.YarnResourceManager                     - Received new container: container_1523253511658_0065_01_000008 - Remaining pending container requests: 1
2018-05-05 04:33:45,669 INFO  org.apache.flink.yarn.YarnResourceManager                     - Creating container launch context for TaskManagers
2018-05-05 04:33:45,669 INFO  org.apache.flink.yarn.YarnResourceManager                     - Starting TaskManagers
2018-05-05 04:33:45,671 INFO  org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy  - Opening proxy : dacoe2.weave.local:20265
2018-05-05 04:33:46,499 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager 640b098f3a132b452a74673631a0bf7f at the SlotManager.
2018-05-05 04:33:46,574 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = aa67216a3bf2630cb4bcf0b558882fc2).
2018-05-05 04:33:46,574 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 9c9860b4a57f48f328f04df3f04b79ae.
2018-05-05 04:33:46,574 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 51294ee3a3ceb12c228611f72168a5d3).
2018-05-05 04:33:46,575 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 47abfb4520010342f83154deaf5787ca).
2018-05-05 04:33:46,575 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 925483bc70d38ca53dac31ecd545abcb.
2018-05-05 04:33:46,575 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = e986f9e6417c4d6cc77a6dd3dedead81).
2018-05-05 04:33:46,575 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 58d588c37208b05fc206244978ad0c8a).
2018-05-05 04:33:46,576 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 4efc22e7371b1960ed3dd90836c72e8b).
2018-05-05 04:33:46,576 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f5fc59b513f1f3019716063162d0eb43.
2018-05-05 04:33:46,576 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 751d87184e37a1826d11fac3271898d6).
2018-05-05 04:33:46,576 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 7d8cbebefe468821f08414d97797614c).
2018-05-05 04:33:46,576 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = cbe031199f7ce49f80b9646522266c74).
2018-05-05 04:33:46,576 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id bbdecaae9eae526df2e01497695aaa44.
2018-05-05 04:33:46,577 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = f1cc0ea4b06f6b5f77431f8e5b7a10d7).
2018-05-05 04:33:46,577 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 2bd8a0c555d6e1ff9481db0a6db61b9f).
2018-05-05 04:33:46,577 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 3da983649f5a334ccb21f74e53ca4059.
2018-05-05 04:33:46,578 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6ea349b6fabb1edae1cdb9f3168b7270).
2018-05-05 04:33:46,578 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 7f3629265059f37dfb0a1ca12b8f504d.
2018-05-05 04:33:46,578 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 5bdf40b8eb62afbdb69d53ce2686ce86).
2018-05-05 04:33:46,579 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 89fd56774dca83e942817cd905494d10).
2018-05-05 04:33:46,579 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 0fa10a0461a55111f48dc10a7a46073e.
2018-05-05 04:33:46,579 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 22804db839ca3549f9b45c94a9c6d0cb).
2018-05-05 04:33:46,579 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = bdcd9449f8a6ccf52d6e7e9547a570e3).
2018-05-05 04:33:46,579 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 2000682a8aef1ee79e74c98668b47107).
2018-05-05 04:33:46,580 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = ad27b4f8835218fc8d9e887edc687ecb).
2018-05-05 04:33:46,580 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = fca5359c70f0a12e75aaf28a0c9e3042).
2018-05-05 04:33:46,580 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 575ea6327ab9df1161e1dc720fd2ffdc).
2018-05-05 04:33:46,580 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id b7649541743ab84c54e18b7adb8df0ff.
2018-05-05 04:33:46,581 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6358123b4aea0c8b97eb80ceaad0417d).
2018-05-05 04:33:46,581 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 15608b05f50929d8cf478a5047aacce0).
2018-05-05 04:33:46,581 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = cef8d25c6d0830be6813cc495b3d592b).
2018-05-05 04:33:46,581 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 77c5c56b6298a30d5ba7557e6622c5d3).
2018-05-05 04:33:46,582 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 151327f699adf0de1f2d37e807d35db4.
2018-05-05 04:33:46,582 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 56f693f4abd3905a0626c92d8ff0ccb1).
2018-05-05 04:33:46,582 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6e490fb9c4fa6efc5ee32a62244ad966).
2018-05-05 04:33:46,582 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6604a0218bcd6447e04c85770e9801ec).
2018-05-05 04:33:46,583 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 8b9ea62f22dfd808cdc623e9e3f65c7d).
2018-05-05 04:33:46,583 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 9c015ca28fbd6f41effa366468b12eaa).
2018-05-05 04:33:46,583 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f8d2fa05b0580663e220fc18e18a94a9.
2018-05-05 04:33:46,583 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 1.
2018-05-05 04:33:46,583 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = bae0806e04d6ca276da721059046b1b3).
2018-05-05 04:33:46,583 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 0b363742f0878819f81392af56f75073.
2018-05-05 04:33:46,584 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 2.
2018-05-05 04:33:46,584 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 72ab90df37a57be0405c1873f452404a.
2018-05-05 04:33:46,584 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 0a654d5b114ea1596988d5f7422d682d).
2018-05-05 04:33:46,584 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 3.
2018-05-05 04:33:46,584 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 63d1d314b6d4a078a5f327e6c2318aa6.
2018-05-05 04:33:46,584 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 4.
2018-05-05 04:33:46,585 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 56059af9f41d1e624434ea2b334840d4).
2018-05-05 04:33:46,585 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 08b34b18625ddaf6714adf0873c88d18.
2018-05-05 04:33:46,585 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 5.
2018-05-05 04:33:46,585 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f194093c7185eb875bfdbb61251e556b.
2018-05-05 04:33:46,585 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 6.
2018-05-05 04:33:46,585 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 5bd04b63226dc5692ab07855a4018ffb.
2018-05-05 04:33:46,586 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 80d025cfb8d88b7134c05074a19402ad).
2018-05-05 04:33:46,586 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 7.
2018-05-05 04:33:46,586 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 60869baadea02627e68b5baddc83e755.
2018-05-05 04:33:46,586 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 8.
2018-05-05 04:33:46,586 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 71b36f567a2c4815ca439c60e4661110.
2018-05-05 04:33:46,586 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 3f1a50be5a07b657b311e6cfee4fbe60).
2018-05-05 04:33:46,586 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 9.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 213a51fa23e6cc0c610dcfa3e55903eb.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 10.
2018-05-05 04:33:46,587 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = bd89eab00a73a2c26d1d41e9e7f540d4).
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id be5ae8ea60df3666e63e8832e5901328.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 11.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id eb7e5ae41a899b3d8d1693ddfe12eb28.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 12.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 7c63e7fbfdc955df477c8357bfcdab48.
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 13.
2018-05-05 04:33:46,587 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 682fc486bbbb67b8232562f30205c30c).
2018-05-05 04:33:46,587 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 13b9bdc7a432e795e275683b68c898fc.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 14.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 836153ccd7c05996c64af55ea3782829.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 15.
2018-05-05 04:33:46,588 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 0c0e234797b6545768d743a3ea3a5342).
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 9c3cdc29a714be4668b56d5d1ff954c8.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 16.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 25ad94838488adb407540b5dab8d89b8.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 17.
2018-05-05 04:33:46,588 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 32210331b7d2d953ba7ed228fb0490e3.
2018-05-05 04:33:46,588 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 18385a852335b7cc6fc864928a4eb342).
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 18.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 116d6ca8887512f77248ed6d223a4895.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 19.
2018-05-05 04:33:46,589 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 29f71b0c36b8e8915dedc9b5f8a0a809).
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 238c0d29996763133ba3114b62a11a1a.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 20.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id bab9e2aa74080a32f031842846416d96.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 21.
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id d36e1300946089b38ad9beb0d0e19729.
2018-05-05 04:33:46,589 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 354741cf93e366eb66341134817cf69e).
2018-05-05 04:33:46,589 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 22.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 77273a56e2950fc90b87ce2f5770f943.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 23.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 3d0f2dcd3814e2b39073e50d6b945845.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 24.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 2d1efe67ca1fa738f084c5a75f909b5a.
2018-05-05 04:33:46,590 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 30df3315283e36a4acc190746c6e8a30).
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 25.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id c003484261ac9e663b8bf355930c7694.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 26.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 4bc319f391f6368b8844d5b8d478ba4a.
2018-05-05 04:33:46,590 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 27.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id ab5a003e661d8b7407783a4642a243b1.
2018-05-05 04:33:46,591 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = eee90ddeae42cc05a9d7a360857b7f71).
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 28.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id aa5001f9a2c6b1e57da9e00fcf3fcab9.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 29.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id d520983ff577ea59c385f9da9b79092b.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 30.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f033eed9982b16fc6720d25e2babf701.
2018-05-05 04:33:46,591 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c20e439c581f2816200099fa972f1132).
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 31.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f98bf8e9bf2210e5cf42fed6e5581805.
2018-05-05 04:33:46,591 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 32.
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 415125d9e8ebb89994b0cbd5725716ac.
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 33.
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id a360c28407e0ddbd0ddbd041bca52835.
2018-05-05 04:33:46,592 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 4d8b60102350001a227bf023b8dea240).
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 34.
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 1c2152a2c0755a1a1df9d2aff732f5fe.
2018-05-05 04:33:46,592 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c7090d81dc570c4511eabba7aa03607f).
2018-05-05 04:33:46,592 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 35.
2018-05-05 04:33:46,593 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id fd6f6e7a43cafbd63b546ce607ce0827.
2018-05-05 04:33:46,593 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 36.
2018-05-05 04:33:46,593 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 6e29a1254db8d9c0c55a7c8df1093d44).
2018-05-05 04:33:46,593 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id a1aff0c3e1411af1c00919aa155bed6a.
2018-05-05 04:33:46,593 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c858bbc8884ebbe05f34bb9e5ed736f7).
2018-05-05 04:33:46,594 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 37.
2018-05-05 04:33:46,594 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 233a80db5f84f5ff0ea198cfa9af9c39.
2018-05-05 04:33:46,594 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 38.
2018-05-05 04:33:46,594 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 8bb4cac33416b8a20e8e233331d42fea).
2018-05-05 04:33:46,595 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id e1a1c52bbd2c3225e728d582e867c919.
2018-05-05 04:33:46,595 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 39.
2018-05-05 04:33:46,595 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 22207519d3448c6a600ffe42d886ce74).
2018-05-05 04:33:46,595 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 551cc9dab5641a56abe8bad2b9c82e3f.
2018-05-05 04:33:46,595 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 40.
2018-05-05 04:33:46,596 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 69ec40f35cac20fddc8349ac3e662252).
2018-05-05 04:33:46,596 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 3ebf67b27dfd79cee511a280529f0069.
2018-05-05 04:33:46,596 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 41.
2018-05-05 04:33:46,596 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 3c56fd3f71ef13bdc81cc3c152440b3f).
2018-05-05 04:33:46,596 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id da85b74fb4562dcf5a6c4a0656430cfe.
2018-05-05 04:33:46,597 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 42.
2018-05-05 04:33:46,597 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 3f9dbba438642724934da615c6299cd2).
2018-05-05 04:33:46,597 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 92b8dc8f7d96ca9bd02379e886ce3d69.
2018-05-05 04:33:46,597 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 43.
2018-05-05 04:33:46,597 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 62ba66a8dcb8bb824e4cf587d1c8fb97).
2018-05-05 04:33:46,597 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 5b21b635ffabefb339eacb42e72b7bb3.
2018-05-05 04:33:46,598 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 44.
2018-05-05 04:33:46,598 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = e08240248011aafb7a09948f6c0f6f72).
2018-05-05 04:33:46,598 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 62183ddfaa90274edc8c378bab9e3460.
2018-05-05 04:33:46,598 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 45.
2018-05-05 04:33:46,598 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = e6d3d3e88d3224bc55fd83c82325a730).
2018-05-05 04:33:46,598 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 0e04a42c48246d1cd3765ea7e554f18b.
2018-05-05 04:33:46,599 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 46.
2018-05-05 04:33:46,599 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a12e2aacac2c637d28aefcbd958b696f).
2018-05-05 04:33:46,599 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 339975258b3ab83d2c81af36859fcb45.
2018-05-05 04:33:46,599 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 47.
2018-05-05 04:33:46,599 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = dca1493806995b3d82cc52f8f0372eb0).
2018-05-05 04:33:46,599 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 4c2c50f64fd7247cda0add17eac6a92b.
2018-05-05 04:33:46,599 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 48.
2018-05-05 04:33:46,600 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 41ca47d3b489ba3898fbc74995f960ba).
2018-05-05 04:33:46,600 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f85d04c7fe4996d018f5523f647a9146.
2018-05-05 04:33:46,600 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 49.
2018-05-05 04:33:46,600 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 00bb8df1be93d92d28f0b954c9163b32).
2018-05-05 04:33:46,600 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id d9f10ffc73daf9153f6885b8fdb88028.
2018-05-05 04:33:46,600 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 50.
2018-05-05 04:33:46,601 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 168bfe1882cf76ce015be3606a588978).
2018-05-05 04:33:46,601 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 64abe18e7d9e6908d06764fcd6eb8644.
2018-05-05 04:33:46,601 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 51.
2018-05-05 04:33:46,601 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 2d0e1e13b4795a88ec1c8c5b6e0abdc5).
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 993a59c7b7c7f681e9f93b75aa6f268d.
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 52.
2018-05-05 04:33:46,602 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a722875cf79e3a750cf4dc2ed08b1d82).
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 23425c2584f7ccf4ddbfc44de8823253.
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 53.
2018-05-05 04:33:46,602 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 2f772bc3f6cd809e972bbe4b9ed2feeb).
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 4c8d7d89a871e42ad8c6527b9b859e5a.
2018-05-05 04:33:46,602 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 54.
2018-05-05 04:33:46,602 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 188f3a640fb1cb75483afe6e148853e5).
2018-05-05 04:33:46,603 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id ef581aa0d37f943bb5523b10e34a0d3c.
2018-05-05 04:33:46,603 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 55.
2018-05-05 04:33:46,603 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = dbe5b0c87fc6459347288baf1e4bfe1d).
2018-05-05 04:33:46,603 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id a14c62957c79a8d05ac4edbef3720b01.
2018-05-05 04:33:46,603 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 56.
2018-05-05 04:33:46,604 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = e71ee4589b7530afb5b60dd2752ea861).
2018-05-05 04:33:46,604 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id dbdb21f38c76cf98ca7467aabece35fd.
2018-05-05 04:33:46,604 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 57.
2018-05-05 04:33:46,604 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = d1cb900ab2fd3fdf6c6a38cf7cc92143).
2018-05-05 04:33:46,604 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id ddba59e0a2937e082efeec73b553d0ea.
2018-05-05 04:33:46,604 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 58.
2018-05-05 04:33:46,604 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c07a324918c89d1272db8a9a81a472ec).
2018-05-05 04:33:46,605 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 6093ef79c07daa57ec4b31838d257a46.
2018-05-05 04:33:46,605 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 59.
2018-05-05 04:33:46,605 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a2f9c71d5fa9b5cde4d45f3896a9343e).
2018-05-05 04:33:46,605 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 4d9cff896e9ff3b8eb5e67970e5904ee.
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 60.
2018-05-05 04:33:46,606 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = b0032aa393f72b25212487064774cf2e).
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 3028a26da63515dabcb5ce8955f4adfb.
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 61.
2018-05-05 04:33:46,606 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = d83cafb27c0180fe8a7ccb4087f6b861).
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id de8f2c4bcff5c39fe821bf644c492bdd.
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 62.
2018-05-05 04:33:46,606 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 49f5b6c2021a68826bc50cd998d6d405).
2018-05-05 04:33:46,606 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 5c353572be384519007c58a9e69552b7.
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 63.
2018-05-05 04:33:46,607 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = b64e511fd79ec1e5023de97c212183f1).
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 4b5bf70eec7a74ca263e38dec10349fa.
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 64.
2018-05-05 04:33:46,607 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 14013c5a4c69b1587eab12dd19cd1b00).
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id e6eec80f4babf81b4c27f35b2dce8f45.
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 65.
2018-05-05 04:33:46,607 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a3f4c1e3c408634a5dfbc445ac1fb1ab).
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id bbf7c6572567cf1e37372b4ebdfd427c.
2018-05-05 04:33:46,607 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 66.
2018-05-05 04:33:46,608 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 1451470a41335be697ab025e220b97e6).
2018-05-05 04:33:46,608 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 9407f828efe197802d2a8114c0ce7727.
2018-05-05 04:33:46,608 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a862991c2bbb6dca46a1913b0c83e03c).
2018-05-05 04:33:46,608 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 67.
2018-05-05 04:33:46,608 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id dded71d16bdc1ed2152fbdbd3612870d.
2018-05-05 04:33:46,608 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 68.
2018-05-05 04:33:46,608 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 323b41d3d47db40506ffccaad8d1c02e).
2018-05-05 04:33:46,609 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 94cc4b90d4cc1ffa633be8d42651a211.
2018-05-05 04:33:46,609 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 69.
2018-05-05 04:33:46,609 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = a72f700ac1532b53da1dcebff856c1c8).
2018-05-05 04:33:46,609 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 2f5573cbe49347f31a3d34776f30174d.
2018-05-05 04:33:46,609 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 70.
2018-05-05 04:33:46,609 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = ee07409c878dc69cf884909a3f270286).
2018-05-05 04:33:46,609 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 8da8a975a744ddcd0a12eb997c27136d.
2018-05-05 04:33:46,610 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 71.
2018-05-05 04:33:46,610 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c57e7399d9ae1aab39e2f17932c1fb66).
2018-05-05 04:33:46,610 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 84ad2abaab66a9e1de3fce9080abd04d.
2018-05-05 04:33:46,610 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 72.
2018-05-05 04:33:46,610 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = e789d9af73d1fd2b3b4dd00324278e4e).
2018-05-05 04:33:46,610 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 6d96e3eeaf5df854b7df89e7fa7e71d6.
2018-05-05 04:33:46,610 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 73.
2018-05-05 04:33:46,611 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = c22905d3252db2e8eeb2a1d254da54a1).
2018-05-05 04:33:46,611 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id b8242ab61071d2cfb2c8336126550c16.
2018-05-05 04:33:46,611 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 74.
2018-05-05 04:33:46,611 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = b5850f3652ee8943f18835423e4f6b1c).
2018-05-05 04:33:46,611 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id a22251749a40cd7d912cf948bfae8e9f.
2018-05-05 04:33:46,611 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 75.
2018-05-05 04:33:46,611 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 01036f66d56ef6f7c6b98978cc1736f6).
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id ef359ef7e9fa0346bccf6fffb38c9122.
2018-05-05 04:33:46,612 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = b20648c3f2e9a00b9ec2e8b6dbf1e039).
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 76.
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 5cfb766506561d4a271129c92e623d4c.
2018-05-05 04:33:46,612 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 9791a126ce19d917ab41b0e049457d5b).
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 77.
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id f9a3bb608f7681a04c4784cdacf1d1e0.
2018-05-05 04:33:46,612 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 78.
2018-05-05 04:33:46,612 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 9a375cced2b585bb6f0b7646cc4b2c20).
2018-05-05 04:33:46,613 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id e250be8097b60550a0cfdb76ff597b16.
2018-05-05 04:33:46,613 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 79.
2018-05-05 04:33:46,613 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = cfc2058d48a56e5c1b816cbde60393b4).
2018-05-05 04:33:46,613 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id fb2b3df2c357bd8f09ca82ecc2737c33.
2018-05-05 04:33:46,613 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 80.
2018-05-05 04:33:46,613 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 3258aa3028966922cd8142db49da8c04).
2018-05-05 04:33:46,614 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id 3162466d481dcc3a365743e8f72ce669.
2018-05-05 04:33:46,614 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 81.
2018-05-05 04:33:46,614 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 53846231d42ef22f824cdb8bca14e65d).
2018-05-05 04:33:46,614 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 88da41a451220f21754691ddcdf29348).
2018-05-05 04:33:46,614 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id d78500573a6b4395e2ee39c28ed158f1.
2018-05-05 04:33:46,614 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 82.
2018-05-05 04:33:46,614 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id cb06b534cae97d455d3c43b6f7c18667.
2018-05-05 04:33:46,615 INFO  org.apache.flink.runtime.jobmaster.slotpool.SlotPool          - Requesting slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager (request = 8a52c956d3c199cb7caff30a151aa1a5).
2018-05-05 04:33:46,615 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 83.
2018-05-05 04:33:46,615 INFO  org.apache.flink.yarn.YarnResourceManager                     - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 18d36ace3769df9f8bfcb20cbf1e4241 with allocation id b68b995690fa808b46027479a4dd7b66.
2018-05-05 04:33:46,615 INFO  org.apache.flink.yarn.YarnResourceManager                     - Requesting new TaskExecutor container with resources <memory:51200, vCores:16>. Number pending requests 84.
2018-05-05 04:33:48,772 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager f5ca1f4b9ad74e3013f51ac1ccadd307 at the SlotManager.
2018-05-05 04:33:49,279 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager 01643a15011c604f535c66b779a87f58 at the SlotManager.
2018-05-05 04:33:49,554 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager e41725c33acf53c33e1c2bfce45ae264 at the SlotManager.
2018-05-05 04:33:50,075 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager a0029b5e8ead37c05fb71dba447fc14f at the SlotManager.
2018-05-05 04:33:50,510 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager e34302090627d2286bf85e550f0b92cb at the SlotManager.
2018-05-05 04:33:50,564 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager  - Register TaskManager 6c9b0e635702551d3e3fc7810e0ac0d0 at the SlotManager.
2018-05-05 04:33:50,625 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (e96c5db22f9da512626201c7583ea1f0) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,626 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Sink: Unnamed (1/1) (attempt #0) to dacoe5
2018-05-05 04:33:50,642 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (2/7) (3203f012de92bf645c062325bff008e4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,642 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (2/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,644 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (3/7) (04f8efd2a0c404c5f90e98bde4b7da43) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,644 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (3/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,645 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (7/7) (0094a247da975e97a6626c4864971dda) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,645 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (7/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,645 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (5/7) (4bf1bce78d3fa71fbb421268031c8a93) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,645 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (5/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,645 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (4/7) (fd8110f559e683a4b64b056146eeaa87) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,646 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (4/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,646 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (1/7) (6605d6809e7379a3906d738019e5d8c3) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,646 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (1/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,646 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (100/100) (63cd5980b9b45a3c0dce0fcafc039bd4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,646 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (100/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,648 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (99/100) (9e0611294f12c9e958a35ea501398d78) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,648 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (99/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,648 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (98/100) (d234de5497675ee73ed20f8249d9e14c) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,648 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (98/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,649 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (97/100) (d8f27f5e140097e2b8e3a32e3b6d32f0) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,649 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (97/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,650 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (96/100) (a436caffb7c42e1753d68375c24cecbb) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,650 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (96/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,651 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (95/100) (b66617d90ce126d95ba876af4c5b7535) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,651 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (95/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,652 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (94/100) (6c6733eea687350fea04232e270a2c9d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,652 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (94/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,652 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (6/7) (08019b5d8369db913acb716cefb38e8d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,652 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (6/7) (attempt #0) to dacoe5
2018-05-05 04:33:50,653 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (93/100) (1e7fec292a896ab3cdffa2cf5e033a62) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,653 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (93/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,654 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (92/100) (19f623d300123a530a1a2670fb0d2aac) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,654 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (92/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,654 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Print to Std. Err (1/1) (be02ec197cfc583b6691ef4b2718fe83) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,654 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Sink: Print to Std. Err (1/1) (attempt #0) to dacoe5
2018-05-05 04:33:50,655 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (f95355491ac9afbfa46444ba096abf93) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,655 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Sink: Unnamed (1/1) (attempt #0) to dacoe5
2018-05-05 04:33:50,656 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (91/100) (ebb37c1c89cec891a5e6a97622fe5bd2) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,656 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (91/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,656 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (90/100) (62698b99c3378da5c911b544fed63be3) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,656 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (90/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,657 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (89/100) (14f4a5c321dc46d785b034c9ab525620) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,657 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (89/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,658 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (88/100) (17fb3272bcd93808600557f18c95307e) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,658 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (88/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,659 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (87/100) (e4079569f5dbbd28822d87325eb4f927) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,659 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (87/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,659 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (86/100) (3b9aa5cd305c2bbfa25c66ff2f4803f8) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,659 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (86/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,660 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (85/100) (26f4b5a28cf30467f29beb5517451802) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,660 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (85/100) (attempt #0) to dacoe5
2018-05-05 04:33:50,661 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (37/100) (158fe84207be7bf750ff59b1746170a0) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,661 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (37/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,661 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (65/100) (ad6cb68d059cf0c8e7e7b635eba9c60c) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,662 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (65/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,662 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (35/100) (eade9f64a219dadef24b52612a9f5ab5) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,662 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (35/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,663 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (58/100) (fa38d38248ad84ef5fd4e749cca8b1ea) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,663 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (58/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,664 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (43/100) (4eca9489afdc900990c96402b0108e80) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,664 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (43/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,664 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (82/100) (ffd5a700d7a766774b32dd9412ec2db2) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,664 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (82/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,665 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (34/100) (68572637ec60d9264c4fa6edb441ba14) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,665 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (34/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,666 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (30/100) (29d6951a99580963e87df38b442aca02) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,666 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (30/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,667 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (76/100) (a6778dcde150c0ef142e37d0bb6c09b1) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,667 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (76/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,667 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (7/100) (3574bc05c74a68876da583c69b0ec1f1) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,667 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (7/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,668 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (22/100) (6e0b300b7829a8bdb8aac3bdce607317) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,668 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (22/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,669 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (80/100) (5ce69ef79e6cd03e773ff769c34c8329) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,669 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (80/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,670 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (14/100) (2b5f68fc2efa948c48d3795d06410cc4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,670 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (14/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,670 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (24/100) (8edcdf9bb84c284ba2683a49691a9e1f) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,670 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (24/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,671 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (18/100) (2586c1068e6cb20aebfa0dc41f9a29ef) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,671 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (18/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,672 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (63/100) (62c4615a4a623245b3c743f2af567578) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,672 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (63/100) (attempt #0) to dacoe3
2018-05-05 04:33:50,672 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (72/100) (ed9f544feb284f79ce5dab9dcf5fcb7b) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,672 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (72/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,673 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (67/100) (342dfcf4d5d7c47a671cafe124791b1d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,673 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (67/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,674 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (57/100) (7cfeb7da03322af2c4a22b6365f913f9) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,674 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (57/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,674 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (3/100) (f47ae87a4b993d178223b624d35ffc42) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,674 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (3/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,674 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (19/100) (c99aa01aa6095f800db0851a67f0a43d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,675 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (19/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,675 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (71/100) (43370e6ae071a21e7aa9fc13b86f0a89) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,675 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (71/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,676 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (20/100) (1c0cea88b36f02668525ef39bb8a0909) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,676 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (20/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,676 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (78/100) (567017acafc028e549fec23c626815ea) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,676 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (78/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,677 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (56/100) (6820e874e9baa5ffb160b93a8a161815) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,677 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (56/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,677 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (28/100) (7150047330a3fe41086cca96719c1770) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,677 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (28/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,678 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (68/100) (320cb4f5f2b418f5a514c60ac34b275f) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,678 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (68/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,678 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (2/100) (c36f9b5eaeb9ae431b7addc9e2eb69a6) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,678 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (2/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (51/100) (5ea488596d34a93234af8ff79fa7a9aa) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (51/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (75/100) (c5c6e6435d67451ae67480542ebc53e4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (75/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (69/100) (e0f53d43cbfa66b71c55ab8d3ced1dcf) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,679 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (69/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,680 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (39/100) (cc8a00e673542268dbdbe64a8e93b043) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,680 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (39/100) (attempt #0) to dacoe6
2018-05-05 04:33:50,681 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (6/100) (a78f13b0e4027591f1476e280d384dc7) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,681 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (6/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,681 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (79/100) (d59fb9051cfb3b5424311868e3383b58) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,681 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (79/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (16/100) (07aefbb36b6dadab84dc90a2960bdb04) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (16/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (11/100) (86cb2d7546011acd2f84ecf4cc443f10) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (11/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (32/100) (0752e696f8b6f73083c0fceae6faa622) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,682 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (32/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,683 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (15/100) (a382314f537ea1d3f6ee8d789d5477c6) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,683 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (15/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,684 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (62/100) (848e8a72bef5198f65c765fb7de10495) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,684 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (62/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,684 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (60/100) (fb124290edd0b5208cedcfa1a3c8acd4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,684 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (60/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,685 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (45/100) (a78cccaac1c36ab36cbe3c11f9f9ee25) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,685 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (45/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,685 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (55/100) (efecbd93dda16c89a0b041c7061ecae7) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,685 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (55/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,686 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (41/100) (ff96ba82a6e6e60fb533af48dffa8541) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,686 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (41/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,686 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (74/100) (ce37e4489767f21f4972c22e930fcd78) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,686 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (74/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,687 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (31/100) (f5703f7e89a6df849706707c2f611daf) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,687 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (31/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,687 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (70/100) (ce715d4f25a0d53fdcb88ea4b27c1934) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,687 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (70/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,688 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (10/100) (74d95462166e0f5c1ee9f3c172446c6f) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,688 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (10/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,688 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (17/100) (2c863ee662f4caee3a1d8f41a7bc71ff) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,688 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (17/100) (attempt #0) to dacoe4
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (61/100) (d8f372eba8b210d34f1126c046bfc37d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (61/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (25/100) (a7108b9634fed9e1d3d2f63fe4c54ac6) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (25/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (59/100) (aaabcf1255ca85971941e482fd2c3d74) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,689 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (59/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,690 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (66/100) (b0d53734eed3795c149edcd63f2071f6) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,690 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (66/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,690 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (48/100) (d1858ec3d0226eca79f5e624019b29dc) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,690 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (48/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,690 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (83/100) (8ba09f39b39526b7f156241a97b7390c) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,691 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (83/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,691 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (49/100) (2c236541a48d41ca0e163dd45906a975) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,691 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (49/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,692 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (4/100) (86a6914c53718d615ebac3d677ea63d1) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,692 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (4/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,692 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (33/100) (7112f35ec539088255b28181b6bfe61c) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,692 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (33/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (42/100) (165ef743e3498c1470e6f2967f229f3a) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (42/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (38/100) (d6ac046d89974dbec7adef0525bf9ac4) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (38/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (46/100) (5a5c2a42e8824d0f578bdc69ae09ae9d) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,693 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (46/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (44/100) (c19c601e7cb0dce6ba573be2e37e4a13) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (44/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (13/100) (211e02e45ffbca123e175367b5a5ddad) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (13/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (77/100) (685872161d99e829d98fa2ff4286d991) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,694 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (77/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,695 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (73/100) (75efa599af96228ad3ff5c8e04f400ee) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,695 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (73/100) (attempt #0) to dacoe7
2018-05-05 04:33:50,695 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (40/100) (c56f0ce39454019b074dcec8c5c04c4b) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,695 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (40/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,696 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (9/100) (e8a90910efd88c68d7230e479e5a5a88) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,696 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (9/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,696 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (12/100) (46cb4d918ff0df31c134c9ba64e54ae9) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,696 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (12/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,697 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (47/100) (73c36ed7a27511aaa344874f22eb9995) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,697 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (47/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,697 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (52/100) (ad5e1a5d9c570e3009593e5442fda0d0) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,697 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (52/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (64/100) (ba41d639728e4e7a6635fe4f2f573034) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (64/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (5/100) (319d2ae3c6ba7a0a1b15a2180c5c8a66) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (5/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (54/100) (f8ddf2d9c97d1e94b59921fc71ff0ecd) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,698 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (54/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,699 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (81/100) (94880940c9278f7a1449dca8d7f645df) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,699 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (81/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,699 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (26/100) (3f00ed8ef2114d8dbe5bb21330b34b66) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,699 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (26/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,699 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (53/100) (7a19aecf023fb73dbe4d7656ce29e959) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,700 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (53/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,700 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (1/100) (56ac25d5ed290f109b3c75123317431f) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,700 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (1/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,701 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (8/100) (91217e9cac8ee010e0f749b890954390) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,701 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (8/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,701 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (36/100) (5d0f778e86c11a01e808320f571a2f5e) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,701 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (36/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (27/100) (fb6f94aae5956a7199098cd33e5fbd09) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (27/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (50/100) (5bf42cf222e2dd971642db4a699e6416) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (50/100) (attempt #0) to dacoe8
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (29/100) (a1445d5308d37bc8d354f0f475b54f8b) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,702 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (29/100) (attempt #0) to dacoe2
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (21/100) (e869c79f2a863ae68b6b639c0f2da9a5) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (21/100) (attempt #0) to dacoe2
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (84/100) (d99329571fef744ef93a7b330fcd8d0b) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (84/100) (attempt #0) to dacoe2
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (23/100) (0e5436624a86c9bdfb4c779fc3d1309b) switched from SCHEDULED to DEPLOYING.
2018-05-05 04:33:50,703 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Deploying Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (23/100) (attempt #0) to dacoe2
2018-05-05 04:33:50,740 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (e96c5db22f9da512626201c7583ea1f0) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,760 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Print to Std. Err (1/1) (be02ec197cfc583b6691ef4b2718fe83) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,763 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Sink: Unnamed (1/1) (f95355491ac9afbfa46444ba096abf93) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,792 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (91/100) (ebb37c1c89cec891a5e6a97622fe5bd2) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,792 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (85/100) (26f4b5a28cf30467f29beb5517451802) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,793 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (89/100) (14f4a5c321dc46d785b034c9ab525620) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,793 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (88/100) (17fb3272bcd93808600557f18c95307e) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,793 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (86/100) (3b9aa5cd305c2bbfa25c66ff2f4803f8) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,794 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (95/100) (b66617d90ce126d95ba876af4c5b7535) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,794 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (99/100) (9e0611294f12c9e958a35ea501398d78) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,796 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (98/100) (d234de5497675ee73ed20f8249d9e14c) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,798 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (87/100) (e4079569f5dbbd28822d87325eb4f927) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,798 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (90/100) (62698b99c3378da5c911b544fed63be3) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,798 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (92/100) (19f623d300123a530a1a2670fb0d2aac) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,799 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (94/100) (6c6733eea687350fea04232e270a2c9d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,799 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (96/100) (a436caffb7c42e1753d68375c24cecbb) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,800 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (93/100) (1e7fec292a896ab3cdffa2cf5e033a62) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,800 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (97/100) (d8f27f5e140097e2b8e3a32e3b6d32f0) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,800 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (100/100) (63cd5980b9b45a3c0dce0fcafc039bd4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,801 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (3/7) (04f8efd2a0c404c5f90e98bde4b7da43) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,801 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (7/7) (0094a247da975e97a6626c4864971dda) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,801 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (2/7) (3203f012de92bf645c062325bff008e4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,802 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (4/7) (fd8110f559e683a4b64b056146eeaa87) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,802 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (1/7) (6605d6809e7379a3906d738019e5d8c3) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,802 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (5/7) (4bf1bce78d3fa71fbb421268031c8a93) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,803 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Source: Custom Source -> Process -> Timestamps/Watermarks -> Map (6/7) (08019b5d8369db913acb716cefb38e8d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,845 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (35/100) (eade9f64a219dadef24b52612a9f5ab5) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,846 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (80/100) (5ce69ef79e6cd03e773ff769c34c8329) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,846 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (43/100) (4eca9489afdc900990c96402b0108e80) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,846 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (82/100) (ffd5a700d7a766774b32dd9412ec2db2) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,847 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (65/100) (ad6cb68d059cf0c8e7e7b635eba9c60c) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,847 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (58/100) (fa38d38248ad84ef5fd4e749cca8b1ea) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,848 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (7/100) (3574bc05c74a68876da583c69b0ec1f1) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,848 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (14/100) (2b5f68fc2efa948c48d3795d06410cc4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,849 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (34/100) (68572637ec60d9264c4fa6edb441ba14) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,849 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (37/100) (158fe84207be7bf750ff59b1746170a0) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,849 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (63/100) (62c4615a4a623245b3c743f2af567578) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,850 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (24/100) (8edcdf9bb84c284ba2683a49691a9e1f) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,850 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (18/100) (2586c1068e6cb20aebfa0dc41f9a29ef) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,850 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (22/100) (6e0b300b7829a8bdb8aac3bdce607317) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,851 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (76/100) (a6778dcde150c0ef142e37d0bb6c09b1) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,851 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (30/100) (29d6951a99580963e87df38b442aca02) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,854 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (41/100) (ff96ba82a6e6e60fb533af48dffa8541) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,855 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (16/100) (07aefbb36b6dadab84dc90a2960bdb04) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,855 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (6/100) (a78f13b0e4027591f1476e280d384dc7) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,855 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (60/100) (fb124290edd0b5208cedcfa1a3c8acd4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,856 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (15/100) (a382314f537ea1d3f6ee8d789d5477c6) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,856 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (45/100) (a78cccaac1c36ab36cbe3c11f9f9ee25) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,856 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (17/100) (2c863ee662f4caee3a1d8f41a7bc71ff) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,857 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (74/100) (ce37e4489767f21f4972c22e930fcd78) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,857 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (32/100) (0752e696f8b6f73083c0fceae6faa622) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,858 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (31/100) (f5703f7e89a6df849706707c2f611daf) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,858 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (79/100) (d59fb9051cfb3b5424311868e3383b58) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,859 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (10/100) (74d95462166e0f5c1ee9f3c172446c6f) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,859 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (11/100) (86cb2d7546011acd2f84ecf4cc443f10) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,860 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (55/100) (efecbd93dda16c89a0b041c7061ecae7) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,860 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (62/100) (848e8a72bef5198f65c765fb7de10495) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,860 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (70/100) (ce715d4f25a0d53fdcb88ea4b27c1934) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,864 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (19/100) (c99aa01aa6095f800db0851a67f0a43d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,864 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (57/100) (7cfeb7da03322af2c4a22b6365f913f9) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,864 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (20/100) (1c0cea88b36f02668525ef39bb8a0909) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,865 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (68/100) (320cb4f5f2b418f5a514c60ac34b275f) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,865 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (67/100) (342dfcf4d5d7c47a671cafe124791b1d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,866 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (71/100) (43370e6ae071a21e7aa9fc13b86f0a89) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,866 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (69/100) (e0f53d43cbfa66b71c55ab8d3ced1dcf) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,866 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (56/100) (6820e874e9baa5ffb160b93a8a161815) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,867 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (2/100) (c36f9b5eaeb9ae431b7addc9e2eb69a6) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,867 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (3/100) (f47ae87a4b993d178223b624d35ffc42) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,867 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (26/100) (3f00ed8ef2114d8dbe5bb21330b34b66) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,867 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (72/100) (ed9f544feb284f79ce5dab9dcf5fcb7b) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,868 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (39/100) (cc8a00e673542268dbdbe64a8e93b043) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,868 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (12/100) (46cb4d918ff0df31c134c9ba64e54ae9) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,868 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (36/100) (5d0f778e86c11a01e808320f571a2f5e) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,868 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (28/100) (7150047330a3fe41086cca96719c1770) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,869 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (8/100) (91217e9cac8ee010e0f749b890954390) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,869 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (78/100) (567017acafc028e549fec23c626815ea) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,869 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (75/100) (c5c6e6435d67451ae67480542ebc53e4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,869 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (9/100) (e8a90910efd88c68d7230e479e5a5a88) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,870 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (51/100) (5ea488596d34a93234af8ff79fa7a9aa) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,871 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (40/100) (c56f0ce39454019b074dcec8c5c04c4b) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,871 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (47/100) (73c36ed7a27511aaa344874f22eb9995) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,871 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (54/100) (f8ddf2d9c97d1e94b59921fc71ff0ecd) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,872 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (81/100) (94880940c9278f7a1449dca8d7f645df) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,873 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (64/100) (ba41d639728e4e7a6635fe4f2f573034) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,874 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (1/100) (56ac25d5ed290f109b3c75123317431f) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,875 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (5/100) (319d2ae3c6ba7a0a1b15a2180c5c8a66) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,876 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (50/100) (5bf42cf222e2dd971642db4a699e6416) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,876 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (53/100) (7a19aecf023fb73dbe4d7656ce29e959) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,876 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (27/100) (fb6f94aae5956a7199098cd33e5fbd09) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,877 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (52/100) (ad5e1a5d9c570e3009593e5442fda0d0) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,882 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (61/100) (d8f372eba8b210d34f1126c046bfc37d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,882 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (73/100) (75efa599af96228ad3ff5c8e04f400ee) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,883 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (23/100) (0e5436624a86c9bdfb4c779fc3d1309b) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,883 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (44/100) (c19c601e7cb0dce6ba573be2e37e4a13) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,883 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (33/100) (7112f35ec539088255b28181b6bfe61c) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,884 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (84/100) (d99329571fef744ef93a7b330fcd8d0b) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,884 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (48/100) (d1858ec3d0226eca79f5e624019b29dc) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,884 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (21/100) (e869c79f2a863ae68b6b639c0f2da9a5) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,884 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (77/100) (685872161d99e829d98fa2ff4286d991) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,885 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (29/100) (a1445d5308d37bc8d354f0f475b54f8b) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,885 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (66/100) (b0d53734eed3795c149edcd63f2071f6) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,886 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (4/100) (86a6914c53718d615ebac3d677ea63d1) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,886 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (38/100) (d6ac046d89974dbec7adef0525bf9ac4) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,886 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (83/100) (8ba09f39b39526b7f156241a97b7390c) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,887 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (42/100) (165ef743e3498c1470e6f2967f229f3a) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,887 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (59/100) (aaabcf1255ca85971941e482fd2c3d74) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,888 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (25/100) (a7108b9634fed9e1d3d2f63fe4c54ac6) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,888 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (13/100) (211e02e45ffbca123e175367b5a5ddad) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,889 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (46/100) (5a5c2a42e8824d0f578bdc69ae09ae9d) switched from DEPLOYING to RUNNING.
2018-05-05 04:33:50,889 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph        - Window(EventTimeSessionWindows(600000), CustomTrigger, SimpleRequestAggregator, PassThroughWindowFunction) -> (Map, Sink: Unnamed) (49/100) (2c236541a48d41ca0e163dd45906a975) switched from DEPLOYING to RUNNING.
2018-05-05 04:53:38,281 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering checkpoint 1 @ 1525496018181 for job 18d36ace3769df9f8bfcb20cbf1e4241.
2018-05-05 04:54:17,853 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Completed checkpoint 1 for job 18d36ace3769df9f8bfcb20cbf1e4241 (40847144904 bytes in 38943 ms).
2018-05-05 05:13:38,231 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering checkpoint 2 @ 1525497218181 for job 18d36ace3769df9f8bfcb20cbf1e4241.
2018-05-05 05:15:10,740 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Completed checkpoint 2 for job 18d36ace3769df9f8bfcb20cbf1e4241 (66986658291 bytes in 90422 ms).
2018-05-05 05:33:38,236 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Triggering checkpoint 3 @ 1525498418181 for job 18d36ace3769df9f8bfcb20cbf1e4241.
2018-05-05 05:35:56,899 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator     - Completed checkpoint 3 for job 18d36ace3769df9f8bfcb20cbf1e4241 (84430092757 bytes in 136952 ms).