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@akka.tcp://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@akka.tcp://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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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 . 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).