Skip to content

Instantly share code, notes, and snippets.

@gyfora

gyfora/gist:693b9a720aace843ff4570e504c4a242 Secret

Created May 29, 2017 14:42
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save gyfora/693b9a720aace843ff4570e504c4a242 to your computer and use it in GitHub Desktop.
Save gyfora/693b9a720aace843ff4570e504c4a242 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
gistfile1.txt
2017-05-29 16:31:45,914 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - --------------------------------------------------------------------------------
2017-05-29 16:31:45,915 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Starting YARN ApplicationMaster / ResourceManager / JobManager (Version: 1.3.0, Rev:760eea8, Date:26.05.2017 @ 16:06:53 CEST)
2017-05-29 16:31:45,915 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Current user: splat
2017-05-29 16:31:45,915 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.131-b11
2017-05-29 16:31:45,916 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Maximum heap size: 406 MiBytes
2017-05-29 16:31:45,916 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - JAVA_HOME: /fjord/java/
2017-05-29 16:31:45,917 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Hadoop version: 2.6.0
2017-05-29 16:31:45,917 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - JVM Options:
2017-05-29 16:31:45,917 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Xmx424m
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -XX:+PrintGCDetails
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -XX:+PrintGCTimeStamps
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -XX:+PrintGCDateStamps
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote.authenticate=false
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote.ssl=false
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote.port=0
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote.local.only=false
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dcom.sun.management.jmxremote.autodiscovery=true
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dlog.file=/fjord/hadoop/data/5/yarn/container-logs/application_1495902768085_0010/container_1495902768085_0010_01_000001/jobmanager.log
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dlogback.configurationFile=file:logback.xml
2017-05-29 16:31:45,918 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - -Dlog4j.configuration=file:log4j.properties
2017-05-29 16:31:45,919 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Program Arguments: (none)
2017-05-29 16:31:45,919 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Classpath: lib/flink-dist_2.10-1.3.0.jar:lib/flink-python_2.10-1.3.0.jar:lib/flink-shaded-hadoop2-uber-1.3.0.jar:lib/log4j-1.2.17.jar:lib/slf4j-log4j12-1.7.7.jar:log4j.properties:logback.xml:rbea-on-flink-2.0-SNAPSHOT.jar:flink.jar:flink-conf.yaml::/etc/hadoop/conf.cloudera.yarn2:/run/cloudera-scm-agent/process/1199-yarn-NODEMANAGER:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-jackson.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-pig-bundle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-encoding.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-auth-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format-sources.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-annotations-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-azure-datalake.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-2.6.0-cdh5.11.0-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-scrooge_2.10.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-thrift.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-cascading.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-nfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-aws.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-protobuf.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-annotations.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-aws-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-auth.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-pig.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-hadoop.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-nfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-hadoop-bundle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-generator.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-test-hadoop2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-column.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-scala_2.10.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-tools.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-avro.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format-javadoc.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-azure-datalake-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/logredactor-1.0.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-beanutils-core-1.8.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-framework-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-client-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/api-util-1.0.0-M20.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-sts-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/api-asn1-api-1.0.0-M20.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-math3-3.1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-s3-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jaxb-api-2.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/snappy-java-1.0.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-compress-1.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/azure-data-lake-store-sdk-2.1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/httpclient-4.2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsp-api-2.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-configuration-1.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/gson-2.2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/java-xmlbuilder-0.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/zookeeper.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-net-3.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-httpclient-3.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jasper-runtime-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-dynamodb-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/avro.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-digester-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-collections-3.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jackson-jaxrs-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-recipes-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/xmlenc-0.52.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-beanutils-1.9.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jaxb-impl-2.2.3-1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jets3t-0.9.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-el-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/stax-api-1.0-2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/slf4j-log4j12.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/hue-plugins-3.9.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/mockito-all-1.8.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/activation-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jasper-compiler-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jackson-xc-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/paranamer-2.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/junit-4.11.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-kms-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/slf4j-api-1.7.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-json-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/htrace-core4-4.0.1-incubating.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/hamcrest-core-1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsch-0.1.42.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jettison-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-core-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/xz-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/apacheds-i18n-2.0.0-M15.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/httpcore-4.2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/netty-3.10.5.Final.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-nfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-nfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-2.6.0-cdh5.11.0-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/leveldbjni-all-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jsp-api-2.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xercesImpl-2.9.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jasper-runtime-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xmlenc-0.52.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-el-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jackson-core-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/htrace-core4-4.0.1-incubating.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-daemon-1.0.13.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jackson-mapper-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xml-apis-1.3.04.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/netty-3.10.5.Final.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-api.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-client-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-nodemanager-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-tests-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-nodemanager.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-client.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-web-proxy.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-registry.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-web-proxy-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-registry-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-api-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/spark-yarn-shuffle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guice-servlet-3.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jaxb-api-2.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/leveldbjni-all-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-compress-1.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/zookeeper.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-client-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/aopalliance-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-collections-3.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-jaxrs-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-guice-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jaxb-impl-2.2.3-1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/stax-api-1.0-2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/activation-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-core-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guice-3.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-xc-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jline-2.11.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-json-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-mapper-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jettison-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/xz-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/spark-1.6.0-cdh5.11.0-yarn-shuffle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/javax.inject-1.jar
2017-05-29 16:31:45,919 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - --------------------------------------------------------------------------------
2017-05-29 16:31:45,920 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Registered UNIX signal handlers for [TERM, HUP, INT]
2017-05-29 16:31:45,927 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - remoteKeytabPrincipal obtained null
2017-05-29 16:31:45,927 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - YARN daemon is running as: splat Yarn client user obtainer: splat
2017-05-29 16:31:45,933 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Loading config from directory /fjord/hadoop/data/nvme/splat/yarn-local-dir/usercache/splat/appcache/application_1495902768085_0010/container_1495902768085_0010_01_000001
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: akka.ask.timeout, 120 s
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: akka.client.timeout, 1200 s
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: akka.lookup.timeout, 120 s
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: env.java.opts, -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=0 -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote.autodiscovery=true
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: fs.hdfs.hadoopconf, /home/splat/rbea-on-flink/deployment/environments/test/yarn-conf
2017-05-29 16:31:45,936 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: parallelism.default, 36
2017-05-29 16:31:45,937 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: recovery.mode, zookeeper
2017-05-29 16:31:45,942 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: recovery.zookeeper.path.root, /flink-splat
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: recovery.zookeeper.quorum, zk04.sto.midasplayer.com:2181,zk05.sto.midasplayer.com:2181,zk06.sto.midasplayer.com:2181
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: recovery.zookeeper.storageDir, hdfs:///flink/ha
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: state.checkpoints.dir, hdfs:///flink/external-checkpoints/rakdos
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: state.savepoints.dir, hdfs:///flink/external-checkpoints/rakdos
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.application-attempts, 10
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.containers.vcores, 12
2017-05-29 16:31:45,943 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.heap-cutoff-ratio, 0.1
2017-05-29 16:31:45,944 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.maximum-failed-containers, 100
2017-05-29 16:31:45,978 INFO org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set to splat (auth:SIMPLE)
2017-05-29 16:31:45,991 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - YARN assigned hostname for application master: splat36.sto.midasplayer.com
2017-05-29 16:31:45,996 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TaskManagers will be created with 9 task slots
2017-05-29 16:31:45,996 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TaskManagers will be started with container size 20000 MB, JVM heap size 18000 MB, JVM direct memory limit -1 MB
2017-05-29 16:31:45,997 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Trying to start actor system at splat36.sto.midasplayer.com:47679
2017-05-29 16:31:46,332 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
2017-05-29 16:31:46,431 INFO Remoting - Starting remoting
2017-05-29 16:31:46,552 INFO Remoting - Remoting started; listening on addresses :[akka.tcp://flink@splat36.sto.midasplayer.com:47679]
2017-05-29 16:31:46,558 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Actor system started at akka.tcp://flink@splat36.sto.midasplayer.com:47679
2017-05-29 16:31:46,558 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Actor system bound to hostname splat36.sto.midasplayer.com.
2017-05-29 16:31:46,563 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TM:remote keytab path obtained null
2017-05-29 16:31:46,563 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TM:remote keytab principal obtained null
2017-05-29 16:31:46,563 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TM:remote yarn conf path obtained null
2017-05-29 16:31:46,563 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - TM:remote krb5 path obtained null
2017-05-29 16:31:47,146 INFO org.apache.flink.yarn.Utils - Copying from file:/fjord/hadoop/data/nvme/splat/yarn-local-dir/usercache/splat/appcache/application_1495902768085_0010/container_1495902768085_0010_01_000001/d3c6e901-2e86-4f21-ad09-e4e8400bff3b-taskmanager-conf.yaml to hdfs://splatnameservice/user/splat/.flink/application_1495902768085_0010/d3c6e901-2e86-4f21-ad09-e4e8400bff3b-taskmanager-conf.yaml
2017-05-29 16:31:47,539 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Prepared local resource for modified yaml: resource { scheme: "hdfs" host: "splatnameservice" port: -1 file: "/user/splat/.flink/application_1495902768085_0010/d3c6e901-2e86-4f21-ad09-e4e8400bff3b-taskmanager-conf.yaml" } size: 1290 timestamp: 1496068307435 type: FILE visibility: APPLICATION
2017-05-29 16:31:47,543 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Creating container launch context for TaskManagers
2017-05-29 16:31:47,544 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Starting TaskManagers with command: $JAVA_HOME/bin/java -Xms18000m -Xmx18000m -XX:+PrintGCDetails -XX:+PrintGCTimeStamps -XX:+PrintGCDateStamps -Dcom.sun.management.jmxremote -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false -Dcom.sun.management.jmxremote.port=0 -Dcom.sun.management.jmxremote.local.only=false -Dcom.sun.management.jmxremote.autodiscovery=true -Dlog.file=<LOG_DIR>/taskmanager.log -Dlogback.configurationFile=file:./logback.xml -Dlog4j.configuration=file:./log4j.properties org.apache.flink.yarn.YarnTaskManager --configDir . 1> <LOG_DIR>/taskmanager.out 2> <LOG_DIR>/taskmanager.err
2017-05-29 16:31:47,556 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.mode' instead of proper key 'high-availability'
2017-05-29 16:31:47,557 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.mode' instead of proper key 'high-availability'
2017-05-29 16:31:47,557 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.zookeeper.storageDir' instead of proper key 'high-availability.storageDir'
2017-05-29 16:31:47,587 INFO org.apache.flink.runtime.blob.FileSystemBlobStore - Creating highly available BLOB storage directory at hdfs:///flink/ha/application_1495902768085_0010/blob
2017-05-29 16:31:47,612 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.zookeeper.quorum' instead of proper key 'high-availability.zookeeper.quorum'
2017-05-29 16:31:47,612 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.zookeeper.path.root' instead of proper key 'high-availability.zookeeper.path.root'
2017-05-29 16:31:47,613 INFO org.apache.flink.runtime.util.ZooKeeperUtils - Enforcing default ACL for ZK connections
2017-05-29 16:31:47,613 INFO org.apache.flink.runtime.util.ZooKeeperUtils - Using '/flink-splat/application_1495902768085_0010' as Zookeeper namespace.
2017-05-29 16:31:47,658 INFO org.apache.flink.shaded.org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=splat36.sto.midasplayer.com
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_131
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-8-oracle/jre
2017-05-29 16:31:47,663 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=lib/flink-dist_2.10-1.3.0.jar:lib/flink-python_2.10-1.3.0.jar:lib/flink-shaded-hadoop2-uber-1.3.0.jar:lib/log4j-1.2.17.jar:lib/slf4j-log4j12-1.7.7.jar:log4j.properties:logback.xml:rbea-on-flink-2.0-SNAPSHOT.jar:flink.jar:flink-conf.yaml::/etc/hadoop/conf.cloudera.yarn2:/run/cloudera-scm-agent/process/1199-yarn-NODEMANAGER:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-jackson.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-pig-bundle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-encoding.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-auth-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format-sources.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-annotations-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-azure-datalake.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-2.6.0-cdh5.11.0-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-scrooge_2.10.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-thrift.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-cascading.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-nfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-aws.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-protobuf.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-annotations.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-aws-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-auth.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-pig.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-hadoop.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-nfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-hadoop-bundle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-generator.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-test-hadoop2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-column.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-scala_2.10.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-tools.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-avro.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/parquet-format-javadoc.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/hadoop-azure-datalake-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/logredactor-1.0.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-beanutils-core-1.8.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-framework-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-client-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/api-util-1.0.0-M20.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-sts-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/api-asn1-api-1.0.0-M20.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-math3-3.1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-s3-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jaxb-api-2.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/snappy-java-1.0.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-compress-1.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/azure-data-lake-store-sdk-2.1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/httpclient-4.2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsp-api-2.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-configuration-1.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/gson-2.2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/java-xmlbuilder-0.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/zookeeper.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-net-3.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-httpclient-3.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jasper-runtime-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-dynamodb-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/avro.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-digester-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-collections-3.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jackson-jaxrs-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/curator-recipes-2.7.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/xmlenc-0.52.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-beanutils-1.9.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jaxb-impl-2.2.3-1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jets3t-0.9.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-el-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/stax-api-1.0-2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/slf4j-log4j12.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/hue-plugins-3.9.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/mockito-all-1.8.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/activation-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jasper-compiler-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jackson-xc-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/paranamer-2.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/junit-4.11.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-kms-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/slf4j-api-1.7.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-json-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/htrace-core4-4.0.1-incubating.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/hamcrest-core-1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jsch-0.1.42.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/jettison-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/aws-java-sdk-core-1.10.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/xz-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/apacheds-i18n-2.0.0-M15.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/httpcore-4.2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/netty-3.10.5.Final.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-nfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-nfs.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-2.6.0-cdh5.11.0-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/hadoop-hdfs-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/leveldbjni-all-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jsp-api-2.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xercesImpl-2.9.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jasper-runtime-5.5.23.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xmlenc-0.52.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-el-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jackson-core-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/htrace-core4-4.0.1-incubating.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-daemon-1.0.13.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/jackson-mapper-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/xml-apis-1.3.04.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-hdfs/lib/netty-3.10.5.Final.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-api.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-client-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-common-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-nodemanager-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-tests-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-nodemanager.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-client.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-common.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-web-proxy.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-tests.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-registry.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-web-proxy-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-registry-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/hadoop-yarn-api-2.6.0-cdh5.11.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-core-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/spark-yarn-shuffle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/servlet-api-2.5.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guice-servlet-3.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jaxb-api-2.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/leveldbjni-all-1.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-compress-1.4.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-codec-1.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/zookeeper.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-client-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jetty-util-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/aopalliance-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/protobuf-java-2.5.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-collections-3.2.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-jaxrs-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-guice-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-cli-1.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jaxb-impl-2.2.3-1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/stax-api-1.0-2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guava-11.0.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-lang-2.6.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jetty-6.1.26.cloudera.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/activation-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-core-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/guice-3.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/log4j-1.2.17.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-xc-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jline-2.11.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-json-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jsr305-3.0.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jersey-server-1.9.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-io-2.4.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jackson-mapper-asl-1.8.8.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/jettison-1.1.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/xz-1.0.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/commons-logging-1.1.3.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/asm-3.2.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/spark-1.6.0-cdh5.11.0-yarn-shuffle.jar:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop-yarn/lib/javax.inject-1.jar
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=:/fjord/hadoop/parcels/CDH-5.11.0-1.cdh5.11.0.p0.34/lib/hadoop/lib/native:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=3.16.0-4-amd64
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=yarn
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/var/lib/hadoop-yarn
2017-05-29 16:31:47,664 INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/fjord/hadoop/data/nvme/splat/yarn-local-dir/usercache/splat/appcache/application_1495902768085_0010/container_1495902768085_0010_01_000001
2017-05-29 16:31:47,665 INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=zk04.sto.midasplayer.com:2181,zk05.sto.midasplayer.com:2181,zk06.sto.midasplayer.com:2181 sessionTimeout=60000 watcher=org.apache.flink.shaded.org.apache.curator.ConnectionState@4a1c0752
2017-05-29 16:31:47,677 WARN org.apache.zookeeper.ClientCnxn - SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-2375118068654489640.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
2017-05-29 16:31:47,678 INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server zk05.sto.midasplayer.com/172.26.82.243:2181
2017-05-29 16:31:47,679 ERROR org.apache.flink.shaded.org.apache.curator.ConnectionState - Authentication failed
2017-05-29 16:31:47,679 INFO org.apache.zookeeper.ClientCnxn - Socket connection established to zk05.sto.midasplayer.com/172.26.82.243:2181, initiating session
2017-05-29 16:31:47,685 INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server zk05.sto.midasplayer.com/172.26.82.243:2181, sessionid = 0x25aad58732a904a, negotiated timeout = 40000
2017-05-29 16:31:47,686 INFO org.apache.flink.shaded.org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED
2017-05-29 16:31:47,689 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /tmp/blobStore-435b546a-3977-4875-8504-1d09dc739709
2017-05-29 16:31:47,690 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:44672 - max concurrent requests: 50 - max backlog: 1000
2017-05-29 16:31:47,761 INFO org.apache.flink.runtime.metrics.MetricRegistry - No metrics reporter configured, no metrics will be exposed/reported.
2017-05-29 16:31:47,768 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.zookeeper.storageDir' instead of proper key 'high-availability.storageDir'
2017-05-29 16:31:47,768 INFO org.apache.flink.runtime.jobmanager.MemoryArchivist - Started memory archivist akka://flink/user/$a
2017-05-29 16:31:47,785 WARN org.apache.flink.shaded.org.apache.curator.utils.ZKPaths - The version of ZooKeeper being used doesn't support Container nodes. CreateMode.PERSISTENT will be used instead.
2017-05-29 16:31:47,806 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.mode' instead of proper key 'high-availability'
2017-05-29 16:31:47,807 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - Starting JobManager Web Frontend
2017-05-29 16:31:47,813 INFO org.apache.flink.yarn.YarnJobManager - Starting JobManager at akka.tcp://flink@splat36.sto.midasplayer.com:47679/user/jobmanager.
2017-05-29 16:31:47,813 INFO org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionService - Starting ZooKeeperLeaderElectionService org.apache.flink.runtime.leaderelection.ZooKeeperLeaderElectionService@23fc0edb.
2017-05-29 16:31:47,819 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager log file: /fjord/hadoop/data/5/yarn/container-logs/application_1495902768085_0010/container_1495902768085_0010_01_000001/jobmanager.log
2017-05-29 16:31:47,820 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of JobManager stdout file: /fjord/hadoop/data/5/yarn/container-logs/application_1495902768085_0010/container_1495902768085_0010_01_000001/jobmanager.out
2017-05-29 16:31:47,820 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-373778d8-cd6c-423f-8cc4-19adad3bdebd for the web interface files
2017-05-29 16:31:47,820 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Using directory /tmp/flink-web-484e2603-11a9-42a7-88b1-1896a0bc7017 for web frontend JAR file uploads
2017-05-29 16:31:47,864 INFO org.apache.flink.yarn.YarnJobManager - JobManager akka.tcp://flink@splat36.sto.midasplayer.com:47679/user/jobmanager was granted leadership with leader session ID Some(643956f8-692a-4843-8a02-a153e2aff944).
2017-05-29 16:31:47,870 INFO org.apache.flink.yarn.YarnJobManager - Delaying recovery of all jobs by 120000 milliseconds.
2017-05-29 16:31:48,016 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Web frontend listening at 0.0.0.0:39082
2017-05-29 16:31:48,017 INFO org.apache.flink.runtime.webmonitor.WebRuntimeMonitor - Starting with JobManager akka.tcp://flink@splat36.sto.midasplayer.com:47679/user/jobmanager on port 39082
2017-05-29 16:31:48,017 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Starting ZooKeeperLeaderRetrievalService.
2017-05-29 16:31:48,020 INFO org.apache.flink.runtime.webmonitor.JobManagerRetriever - New leader reachable under akka.tcp://flink@splat36.sto.midasplayer.com:47679/user/jobmanager:643956f8-692a-4843-8a02-a153e2aff944.
2017-05-29 16:31:48,022 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - YARN application tolerates 100 failed TaskManager containers before giving up
2017-05-29 16:31:48,026 INFO org.apache.flink.yarn.YarnApplicationMasterRunner - YARN Application Master started
2017-05-29 16:31:48,035 INFO org.apache.flink.runtime.leaderretrieval.ZooKeeperLeaderRetrievalService - Starting ZooKeeperLeaderRetrievalService.
2017-05-29 16:31:48,036 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Initializing YARN resource master
2017-05-29 16:31:48,045 INFO org.apache.hadoop.yarn.client.RMProxy - Connecting to ResourceManager at splat34.sto.midasplayer.com/172.26.83.103:8030
2017-05-29 16:31:48,064 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - yarn.client.max-cached-nodemanagers-proxies : 0
2017-05-29 16:31:48,064 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Registering Application Master with tracking url http://splat36.sto.midasplayer.com:39082
2017-05-29 16:31:48,170 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Trying to associate with JobManager leader akka.tcp://flink@splat36.sto.midasplayer.com:47679/user/jobmanager
2017-05-29 16:31:48,177 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Resource Manager associating with leading JobManager Actor[akka://flink/user/jobmanager#-1099148036] - leader session 643956f8-692a-4843-8a02-a153e2aff944
2017-05-29 16:31:48,177 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Requesting new TaskManager container with 20000 megabytes memory. Pending requests: 1
2017-05-29 16:31:48,190 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Requesting new TaskManager container with 20000 megabytes memory. Pending requests: 2
2017-05-29 16:31:48,191 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Requesting new TaskManager container with 20000 megabytes memory. Pending requests: 3
2017-05-29 16:31:48,191 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Requesting new TaskManager container with 20000 megabytes memory. Pending requests: 4
2017-05-29 16:31:49,723 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : splat36.sto.midasplayer.com:8041
2017-05-29 16:31:49,724 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : splat35.sto.midasplayer.com:8041
2017-05-29 16:31:49,742 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Received new container: container_1495902768085_0010_01_000002 - Remaining pending container requests: 3
2017-05-29 16:31:49,743 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Launching TaskManager in container ContainerInLaunch @ 1496068309742: Container: [ContainerId: container_1495902768085_0010_01_000002, NodeId: splat36.sto.midasplayer.com:8041, NodeHttpAddress: splat36.sto.midasplayer.com:8042, Resource: <memory:20240, vCores:12>, Priority: 0, Token: Token { kind: ContainerToken, service: 172.26.83.105:8041 }, ] on host splat36.sto.midasplayer.com
2017-05-29 16:31:49,745 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - Opening proxy : splat36.sto.midasplayer.com:8041
2017-05-29 16:31:49,797 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Received new container: container_1495902768085_0010_01_000003 - Remaining pending container requests: 2
2017-05-29 16:31:49,797 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Launching TaskManager in container ContainerInLaunch @ 1496068309797: Container: [ContainerId: container_1495902768085_0010_01_000003, NodeId: splat36.sto.midasplayer.com:8041, NodeHttpAddress: splat36.sto.midasplayer.com:8042, Resource: <memory:20240, vCores:12>, Priority: 0, Token: Token { kind: ContainerToken, service: 172.26.83.105:8041 }, ] on host splat36.sto.midasplayer.com
2017-05-29 16:31:49,797 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - Opening proxy : splat36.sto.midasplayer.com:8041
2017-05-29 16:31:49,805 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Received new container: container_1495902768085_0010_01_000004 - Remaining pending container requests: 1
2017-05-29 16:31:49,806 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Launching TaskManager in container ContainerInLaunch @ 1496068309805: Container: [ContainerId: container_1495902768085_0010_01_000004, NodeId: splat35.sto.midasplayer.com:8041, NodeHttpAddress: splat35.sto.midasplayer.com:8042, Resource: <memory:20240, vCores:12>, Priority: 0, Token: Token { kind: ContainerToken, service: 172.26.83.104:8041 }, ] on host splat35.sto.midasplayer.com
2017-05-29 16:31:49,806 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - Opening proxy : splat35.sto.midasplayer.com:8041
2017-05-29 16:31:49,813 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Received new container: container_1495902768085_0010_01_000005 - Remaining pending container requests: 0
2017-05-29 16:31:49,813 INFO org.apache.flink.yarn.YarnFlinkResourceManager - Launching TaskManager in container ContainerInLaunch @ 1496068309813: Container: [ContainerId: container_1495902768085_0010_01_000005, NodeId: splat35.sto.midasplayer.com:8041, NodeHttpAddress: splat35.sto.midasplayer.com:8042, Resource: <memory:20240, vCores:12>, Priority: 0, Token: Token { kind: ContainerToken, service: 172.26.83.104:8041 }, ] on host splat35.sto.midasplayer.com
2017-05-29 16:31:49,813 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - Opening proxy : splat35.sto.midasplayer.com:8041
2017-05-29 16:31:50,487 INFO org.apache.flink.yarn.YarnJobManager - ApplicationMaster will shut down session when job 28818562367ba62e35b88fb45983bb52 has finished.
2017-05-29 16:31:53,336 INFO org.apache.flink.yarn.YarnFlinkResourceManager - TaskManager container_1495902768085_0010_01_000003 has started.
2017-05-29 16:31:53,340 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at splat36 (akka.tcp://flink@splat36.sto.midasplayer.com:37352/user/taskmanager) as 3546e9b92c69e7ad57f89331e5648e97. Current number of registered hosts is 1. Current number of alive task slots is 9.
2017-05-29 16:31:53,371 INFO org.apache.flink.yarn.YarnFlinkResourceManager - TaskManager container_1495902768085_0010_01_000002 has started.
2017-05-29 16:31:53,372 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at splat36 (akka.tcp://flink@splat36.sto.midasplayer.com:34292/user/taskmanager) as 854f1fdf9ae596faa68cd6e1a45a4c7b. Current number of registered hosts is 2. Current number of alive task slots is 18.
2017-05-29 16:31:53,805 INFO org.apache.flink.yarn.YarnFlinkResourceManager - TaskManager container_1495902768085_0010_01_000004 has started.
2017-05-29 16:31:53,805 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at splat35 (akka.tcp://flink@splat35.sto.midasplayer.com:32812/user/taskmanager) as 6b0984ab12a7c1816e1b7131611ed1b2. Current number of registered hosts is 3. Current number of alive task slots is 27.
2017-05-29 16:31:53,847 INFO org.apache.flink.yarn.YarnFlinkResourceManager - TaskManager container_1495902768085_0010_01_000005 has started.
2017-05-29 16:31:53,847 INFO org.apache.flink.runtime.instance.InstanceManager - Registered TaskManager at splat35 (akka.tcp://flink@splat35.sto.midasplayer.com:55313/user/taskmanager) as 5ffe402523b5accec862d5861afa9845. Current number of registered hosts is 4. Current number of alive task slots is 36.
2017-05-29 16:31:54,101 INFO org.apache.flink.yarn.YarnJobManager - Submitting job 28818562367ba62e35b88fb45983bb52 (event.rakdos.log).
2017-05-29 16:31:54,113 INFO org.apache.flink.yarn.YarnJobManager - Using restart strategy FixedDelayRestartStrategy(maxNumberRestartAttempts=2147483647, delayBetweenRestartAttempts=10000) for 28818562367ba62e35b88fb45983bb52.
2017-05-29 16:31:54,126 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart
2017-05-29 16:31:54,140 INFO org.apache.flink.yarn.YarnJobManager - Running initialization on master for job event.rakdos.log (28818562367ba62e35b88fb45983bb52).
2017-05-29 16:31:54,140 INFO org.apache.flink.yarn.YarnJobManager - Successfully ran initialization on master in 0 ms.
2017-05-29 16:31:54,167 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'recovery.zookeeper.storageDir' instead of proper key 'high-availability.storageDir'
2017-05-29 16:31:54,174 INFO org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore - Initialized in '/checkpoints/28818562367ba62e35b88fb45983bb52'.
2017-05-29 16:31:54,182 INFO org.apache.flink.yarn.YarnJobManager - Using application-defined state backend for checkpoint/savepoint metadata: RocksDB State Backend {isInitialized=false, configuredDbBasePaths=null, initializedDbBasePaths=null, checkpointStreamBackend=File State Backend @ hdfs://splatnameservice/flink/checkpoints/event.rakdos.log}.
2017-05-29 16:31:54,185 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Persisting periodic checkpoints externally at hdfs:///flink/external-checkpoints/rakdos.
2017-05-29 16:31:54,200 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Starting job from savepoint hdfs:///flink/external-checkpoints/rakdos/checkpoint_metadata-5811ee026ee7 ()
2017-05-29 16:31:54,203 INFO org.apache.flink.runtime.checkpoint.savepoint.SavepointStore - Loading savepoint from hdfs:/flink/external-checkpoints/rakdos/checkpoint_metadata-5811ee026ee7
2017-05-29 16:31:54,423 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Reset the checkpoint ID to 3204.
2017-05-29 16:31:54,424 INFO org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore - Recovering checkpoints from ZooKeeper.
2017-05-29 16:31:54,429 INFO org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore - Found 1 checkpoints in ZooKeeper.
2017-05-29 16:31:54,430 INFO org.apache.flink.runtime.checkpoint.ZooKeeperCompletedCheckpointStore - Trying to retrieve checkpoint 3203.
2017-05-29 16:31:54,471 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Restoring from latest valid checkpoint: Checkpoint 3203 @ 0 for 28818562367ba62e35b88fb45983bb52.
2017-05-29 16:31:54,483 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - No master state to restore
2017-05-29 16:31:54,561 INFO org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore - Added SubmittedJobGraph(28818562367ba62e35b88fb45983bb52, JobInfo(clients: Set((Actor[akka.tcp://flink@deploy.sto.midasplayer.com:37019/temp/$F],DETACHED)), start: 1496068314091)) to ZooKeeper.
2017-05-29 16:31:54,562 INFO org.apache.flink.yarn.YarnJobManager - Scheduling job 28818562367ba62e35b88fb45983bb52 (event.rakdos.log).
2017-05-29 16:31:54,563 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job event.rakdos.log (28818562367ba62e35b88fb45983bb52) switched from state CREATED to RUNNING.
2017-05-29 16:31:54,565 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSource-14 (1/1) (70221cffeb826034ea276ca7674b2436) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,572 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (1/16) (06832d91c00ac69b4546b9b3811e0282) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,573 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (2/16) (3a7a60de0477d9846e9cee9c631c9996) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,573 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (3/16) (666ab64b86256506544ade559a82768f) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,573 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (4/16) (43a56629af2a4649c7df995ac36fefc0) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,573 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (5/16) (927a9a263139fa0b44691a26defe9730) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,573 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (6/16) (5178b5d53cb97b1e403e01bb2b817d19) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (7/16) (251c2f30392170e8c292641e0a9b426b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (8/16) (b771f711bd07ade12529a4d68c13fb46) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (9/16) (856e71bb3569fe18e2b763756798e184) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (10/16) (c5faff50451445af12c178068acfd72d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (11/16) (d4fc1458663bef5abc14ffa3e468b900) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (12/16) (d2d1e23fc1aaaae5772078e4c01680f1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,574 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (13/16) (f7158fd780127babf1c4f065da9a38a5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (14/16) (6b9501d41365171fc6703d495049bbf8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (15/16) (62cf334d17489347c0924db1abbc4b77) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (16/16) (83731e3d7103653b18bf834ba586eee6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (1/16) (b0a334064879afab6b121fc19932a7bc) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (2/16) (acff65ec4d15e1572a9cc1474ed673a2) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,575 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (3/16) (14b7bd967ab6a3941cffef0f7bff1ef8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (4/16) (b12985913bfc18cef974b5d349cee750) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (5/16) (36c901cd588e6b009ede5451417eedf1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (6/16) (1459b81d9737aa3d74b4f7ca3bac7a55) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (7/16) (18b748bc5ceafb2b72db8883521c0cab) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (8/16) (5ab0d6c2db131583fcb286445edc4056) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (9/16) (fcb900b390c2129333f9f4dc46f27e6b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (10/16) (1c6c68f2fb9c8bbca854589a29fb8037) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,576 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (11/16) (7c30ce46569a08f3507cc2d59369a1b8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (12/16) (3b6eb45c2df4bf448a81ee65f54b041f) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (13/16) (40279c4460e29f4a78986c2907c18054) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (14/16) (caeaccf1e2f1b3b97055df8023966971) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (15/16) (0c6aabbd3021cfd55a674acf51941f46) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (16/16) (7a34a4e3f0158df8d1146c00938f70d4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,577 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Query Job Info (1/1) (0e4da403b5f49e1084222901df4aced2) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,578 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1) (e092f6977d7f38ed0e76183a68753b53) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,578 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Fields and Ids -> Filter Errors and Notifications (1/1) (e10212e1c24c0d87375600dd2a1ff89d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,578 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (1/36) (051a748fa704f2d2da94e2a990277a8d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,579 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (2/36) (1dc64cde096addda807f32c2649f41a2) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,579 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (3/36) (bd1ad53e204ec9bde667ea7edbed6ebf) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,579 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (4/36) (8c22856121dab2d820a70b77d806260a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,579 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (5/36) (27a923385cd466c822ec2f87e0f2dee8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (6/36) (082bd2f368345469425518c68dcdb3ff) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (7/36) (85ed2703a6105bdaaa48418f6330b332) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (8/36) (4a2d301a96da9e76fd136c786c192da7) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (9/36) (be858d29b9f44edb994e345b123f07c3) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (10/36) (4b697b61f89480e63d009c50fae0092b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,580 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (11/36) (76c9e632d802f9b4ff8d9fb3ecff2cc4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,581 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (12/36) (33dd774ef026ffa1db61c21b0617f0b3) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,581 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (13/36) (f50ca6a7636a2a4c40659f61c245a65c) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,581 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (14/36) (5101ca6b54ef329068347b9e9cdec266) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,581 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (15/36) (4bdd270c9a1cc28b6516d32d4e842cb5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,581 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (16/36) (958cff3e247c459a24c0eaa2eda4906e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,582 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (17/36) (4e49a3ede0ecb859dfd55edd7673abf5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,582 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (18/36) (2235844f092978a7af2bb4f17f55a0f1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,582 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (19/36) (cd213dd124a5159f3fdaea3a1ebe4445) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,582 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (20/36) (5773ac2635b81f9fdf08045047846e18) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,582 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (21/36) (9d35f93ed023f8445678a10c20a949cd) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,583 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (22/36) (f043ad4c15e9a26b52e986871d93a60b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,583 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (23/36) (e69ebebed77492314d29331adbbf44b5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,583 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (24/36) (a5e7a24954197cf22ef66d600ae02af2) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,583 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (25/36) (3cf95ada57e9294d2ca2d42ee479f125) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,583 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (26/36) (dca989a3b3d73f1d8c796ea1f7eb12f4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,584 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (27/36) (00ac7e184d35178054e93c114fec3f44) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,584 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (28/36) (d99d45e641808cd31a73c4153683a83a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,584 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (29/36) (8929bcffdb86cab2665fa6871c6c533b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,584 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (30/36) (01629d9756db1dfc6f2f2b8168f168ec) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,585 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (31/36) (982f901aaea1c4cc1bdad35b373d8532) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,585 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (32/36) (9fe73b3df4aebe808acfe6ae461e0732) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,585 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (33/36) (960b53efedf89bb595b306529f3a6151) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,585 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (34/36) (b928ad62f15f4e480ae6bb63babf6934) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,586 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (35/36) (16db490845c6f95595d60739247ea7c0) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,586 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (36/36) (62f6668f7c86c13b8f02f36ae781a91a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,586 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (1/36) (44401fe510e235e35c1ba1578d8e6b33) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (2/36) (28d093e9852b9b952cd921d445114ca6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (3/36) (407abb38798cf7d70c055c816a19c983) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (4/36) (27b3bd4a778f1f41ce445c8b7c31150b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (5/36) (99ec69005a750402e77bbd1decde4c35) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (6/36) (eb713d1f5142545c580b25eaa68e782d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,587 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (7/36) (9f1300cea6876924d4e7d7a8668a60cf) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (8/36) (f219ec1b234c8443dded488cefe42f30) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (9/36) (4745607473b65f37cdf4d0d73086e016) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (10/36) (efda312f6d3e099210866747acd1867b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (11/36) (f0017c027796177a91346da4e9685e0e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (12/36) (01fa118aa297202828f48d371625adb1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,588 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (13/36) (49de6dc924cd8c694607a34af05479fc) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (14/36) (e20140a11782b5204b42bdb1ad9f07b9) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (15/36) (a622865a465b51c22bcb2740c45b2e66) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (16/36) (69ff3020d1e536d898978451911e7ab6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (17/36) (15fd5c8635ae6481ad47ff422cc42110) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (18/36) (faf71ffcfbbf64ed6a2784f1414ec00e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,589 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (19/36) (0c65dd5f0892fae3716811454f4ff300) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,590 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (20/36) (96702e65f3e5203c6dec0ba6a0bfb467) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,590 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (21/36) (739c5c3453f35465422eb384196d907a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,590 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (22/36) (bc2967cd3a083ae19e1d9ccd3075a7a4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,590 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (23/36) (6750a298606c89c5e2f53c76a1638103) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,590 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (24/36) (5cf1d6e1b317483b4c7284fbceecaceb) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (25/36) (046c0059edb75cff2eeb92d9646d3761) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (26/36) (73a4949602f06ce5ba21690e7e8feaa1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (27/36) (ff7f5b8ce1e5095118dcbda086cc6199) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (28/36) (1548d81bf8682ebdf5a7d61af8a4ea6b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (29/36) (f2d5408081701337653774097ace38ef) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (30/36) (095606e348a444e0f754d17c11aae92e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (31/36) (9527f1c80d21186e375aad89b3c4d1e8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (32/36) (3b1bc49c16ca67aa359768ca342e270f) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (33/36) (49fb7830e2c79ff3cb2631dc49f46c4a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (34/36) (954e033a050320ba2a1141df770f3773) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (35/36) (bc9bb2ce7dc6ea04f3cf28f8b474c319) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (36/36) (18b512eacbd09aeb806d2ad3143e50ff) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,592 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (1/36) (76be66f0f476c01d38f8ab19fe065c9b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (2/36) (3f01b22294b9725be7f9a9ff44ea9d98) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (3/36) (a3c95029cf5844fbab1050b819dbda54) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (4/36) (fac51d9095478467c1078dfcc8258a63) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (5/36) (71bc304a571ec49cc7eec28b3d57490a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (6/36) (e58d2026a75abfac1f0c7da498fa17c5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (7/36) (c0bedf61b68c843c08bc498e63bb70c1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (8/36) (6d242314dbcff407d889880f98f82962) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (9/36) (12535bc28d239259f2195ef860d124bf) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (10/36) (10f53dce447ba2949db5b4973433d621) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (11/36) (e92bd9fdcfaa96afbf8b3c4327809388) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (12/36) (009446007278cdb24eec92d443b8b826) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (13/36) (0aa4d4e41385a23b032c6b27295e96e1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (14/36) (ac69df9f65cbc8fc0be0ca9eb3713cd5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (15/36) (52e31d86a1e2ff3ad2a1559ef42e03d0) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (16/36) (19838cd9eb590950b492ac10b081f4d5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (17/36) (0c95eb36efbc012a5a50d5e27254fa9a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (18/36) (0987be21a62ff4cad50abf836518e409) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,594 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (19/36) (fd5ceb8557a9d4c7efe0c66a734636c2) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (20/36) (47cde22a4129b2c934d8558e86b0d198) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (21/36) (97d25242328e500efcf691ef60de5f10) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (22/36) (ac9a75e085dbfbe88354170d3bc897e5) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (23/36) (0438e97eac10c23d5b3bc36c46b55587) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (24/36) (a77f147855dfea06d9a695161e0e7497) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (25/36) (f0ce218cefeec3d0faa696179063876c) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (26/36) (61de8760c36cc83e0b92d9035dff5891) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (27/36) (5ac020fc8d210684eb06856d23bb3d44) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,595 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (28/36) (ca94d64cc646e2ee0004f46e4cfa37f9) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (29/36) (c0c7d4a12bd4255721d4dd23bbf5ead6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (30/36) (1bc3572d4a0257b28a64912ed2c75a34) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (31/36) (7066ff88f335748595494934aad57f24) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (32/36) (abc0be309299e5697dab815e9393a9e7) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (33/36) (deca4b063c13d18c85b265da64b9b475) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (34/36) (1a2d2dcb3459bc2ef2404f57cb6004f8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (35/36) (3e4f56a96d5473270e124f8c7ca9604e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (36/36) (2a2a46ab1c1e4d60f794cdb123e48c8a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (1/36) (c8be9d9dca6bf58e6e90f5de2c169032) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (2/36) (3dca5be4e289fd53f6c7dd3b0bedd9e9) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (3/36) (f8c6c1e96facb565e37d8e88f9f13b7d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (4/36) (51f5859e32efafdc1f9db0bfe506fa7e) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,596 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (5/36) (03b5306f5633c5a7658144d6bc3be816) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (6/36) (1b96d9676032e349ba9db9d14761b227) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (7/36) (206a879febc2f8d85ef183091d6329a6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (8/36) (9235c8f0bdc2a9385b8a9cbec7b07a37) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (9/36) (587248d3bae79493b497aae1c1448f0a) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (10/36) (5a487394fbdf5a1d44549e1fd8c020f6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (11/36) (97fc71c1fa29ad06a3100b2c292e29d4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (12/36) (34b207cf0e0318c09fbea04eb178b91d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (13/36) (0846260854e550737a566531e0a465c7) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (14/36) (6a8334bc93cb25bec7bbb0eac1d3d95d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (15/36) (dfa768a7d7cb82af0ca60245d81c305d) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (16/36) (5a52aba1ee00030543cb2654f4962bd7) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (17/36) (acbbe587584908a5aa13593b22177043) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (18/36) (12c3b167129a675bfbd94d3526da4da3) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,597 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (19/36) (145ccaef535103d25e8543e98e51ccda) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (20/36) (4410c015d3e301d6446aa5f3e1bafe4b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (21/36) (0461b30c1d495dc8dbf3c4adddebc5b6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (22/36) (c8b0385fa80b0d62e917b2417daa9f4f) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (23/36) (7f5e9d70521703ae07125be982c21a20) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (24/36) (936923160fdbb441329f528e6a4603a1) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (25/36) (5fd4f890c187f1bc80cbed800b5f8095) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (26/36) (f76e02b1845a43841615b39160b08f28) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (27/36) (c38dbb4799990ec1c33636598436ae47) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (28/36) (fd53b4cd547f2e9542f5cbc5c9c7a63f) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (29/36) (3a128e524d55d79e7ce2d1e33612ae99) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (30/36) (cdfa63a8155de2afa61b68e99cbb6d35) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,598 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (31/36) (537c05cfac4fdacac1b3cf8c40eb8aa6) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (32/36) (2abe87a6385b6a622febcd7f6ddad7cd) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (33/36) (c70aeac8cbec03cf6c99d849a18d40b9) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (34/36) (7087f8cd0451e1123c32de4d50a108be) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (35/36) (1b4294a4c903b6caa9e1e41437bf0bd4) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (36/36) (c18d104a8fbeb676e27adfdc93520132) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - To DeploymentInfo (1/1) (78c698d484b0bdae61acda7f7ab6bd59) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSink-14 (1/1) (837a52b20597bbed15f87f6861d8fb2b) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,599 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Job information (1/1) (9186549a923997f17ea98e8090f252a8) switched from CREATED to SCHEDULED.
2017-05-29 16:31:54,605 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSource-14 (1/1) (70221cffeb826034ea276ca7674b2436) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,605 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying IterationSource-14 (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,609 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (1/16) (06832d91c00ac69b4546b9b3811e0282) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,609 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (1/16) (attempt #0) to splat36
2017-05-29 16:31:54,609 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (2/16) (3a7a60de0477d9846e9cee9c631c9996) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (2/16) (attempt #0) to splat36
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (3/16) (666ab64b86256506544ade559a82768f) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (3/16) (attempt #0) to splat35
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (4/16) (43a56629af2a4649c7df995ac36fefc0) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (4/16) (attempt #0) to splat35
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (5/16) (927a9a263139fa0b44691a26defe9730) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (5/16) (attempt #0) to splat36
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (6/16) (5178b5d53cb97b1e403e01bb2b817d19) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (6/16) (attempt #0) to splat36
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (7/16) (251c2f30392170e8c292641e0a9b426b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,610 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (7/16) (attempt #0) to splat35
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (8/16) (b771f711bd07ade12529a4d68c13fb46) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (8/16) (attempt #0) to splat35
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (9/16) (856e71bb3569fe18e2b763756798e184) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (9/16) (attempt #0) to splat36
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (10/16) (c5faff50451445af12c178068acfd72d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (10/16) (attempt #0) to splat36
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (11/16) (d4fc1458663bef5abc14ffa3e468b900) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (11/16) (attempt #0) to splat35
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (12/16) (d2d1e23fc1aaaae5772078e4c01680f1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,611 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (12/16) (attempt #0) to splat35
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (13/16) (f7158fd780127babf1c4f065da9a38a5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (13/16) (attempt #0) to splat36
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (14/16) (6b9501d41365171fc6703d495049bbf8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (14/16) (attempt #0) to splat36
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (15/16) (62cf334d17489347c0924db1abbc4b77) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (15/16) (attempt #0) to splat35
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (16/16) (83731e3d7103653b18bf834ba586eee6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,612 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[event.rakdos.log] -> Wrap events (16/16) (attempt #0) to splat35
2017-05-29 16:31:54,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (1/16) (b0a334064879afab6b121fc19932a7bc) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (1/16) (attempt #0) to splat36
2017-05-29 16:31:54,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (2/16) (acff65ec4d15e1572a9cc1474ed673a2) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (2/16) (attempt #0) to splat36
2017-05-29 16:31:54,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (3/16) (14b7bd967ab6a3941cffef0f7bff1ef8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (3/16) (attempt #0) to splat36
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (4/16) (b12985913bfc18cef974b5d349cee750) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (4/16) (attempt #0) to splat36
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (5/16) (36c901cd588e6b009ede5451417eedf1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (5/16) (attempt #0) to splat36
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (6/16) (1459b81d9737aa3d74b4f7ca3bac7a55) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (6/16) (attempt #0) to splat36
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (7/16) (18b748bc5ceafb2b72db8883521c0cab) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (7/16) (attempt #0) to splat36
2017-05-29 16:31:54,615 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (8/16) (5ab0d6c2db131583fcb286445edc4056) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,634 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (8/16) (attempt #0) to splat36
2017-05-29 16:31:54,634 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (9/16) (fcb900b390c2129333f9f4dc46f27e6b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,634 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (9/16) (attempt #0) to splat35
2017-05-29 16:31:54,641 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (10/16) (1c6c68f2fb9c8bbca854589a29fb8037) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,641 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (10/16) (attempt #0) to splat35
2017-05-29 16:31:54,641 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (11/16) (7c30ce46569a08f3507cc2d59369a1b8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,641 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (11/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (12/16) (3b6eb45c2df4bf448a81ee65f54b041f) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (12/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (13/16) (40279c4460e29f4a78986c2907c18054) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (13/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (14/16) (caeaccf1e2f1b3b97055df8023966971) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (14/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (15/16) (0c6aabbd3021cfd55a674acf51941f46) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (15/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (16/16) (7a34a4e3f0158df8d1146c00938f70d4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (16/16) (attempt #0) to splat35
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Query Job Info (1/1) (0e4da403b5f49e1084222901df4aced2) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,642 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Query Job Info (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,643 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1) (e092f6977d7f38ed0e76183a68753b53) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,643 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,643 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Fields and Ids -> Filter Errors and Notifications (1/1) (e10212e1c24c0d87375600dd2a1ff89d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,643 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Create Fields and Ids -> Filter Errors and Notifications (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,646 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (1/36) (051a748fa704f2d2da94e2a990277a8d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,646 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (1/36) (attempt #0) to splat36
2017-05-29 16:31:54,647 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (2/36) (1dc64cde096addda807f32c2649f41a2) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,647 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (2/36) (attempt #0) to splat36
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (3/36) (bd1ad53e204ec9bde667ea7edbed6ebf) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (3/36) (attempt #0) to splat36
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (4/36) (8c22856121dab2d820a70b77d806260a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (4/36) (attempt #0) to splat36
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (5/36) (27a923385cd466c822ec2f87e0f2dee8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (5/36) (attempt #0) to splat36
2017-05-29 16:31:54,649 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (6/36) (082bd2f368345469425518c68dcdb3ff) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,649 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (6/36) (attempt #0) to splat36
2017-05-29 16:31:54,649 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (7/36) (85ed2703a6105bdaaa48418f6330b332) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,649 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (7/36) (attempt #0) to splat36
2017-05-29 16:31:54,654 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (8/36) (4a2d301a96da9e76fd136c786c192da7) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,654 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (8/36) (attempt #0) to splat36
2017-05-29 16:31:54,654 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (9/36) (be858d29b9f44edb994e345b123f07c3) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,655 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (9/36) (attempt #0) to splat35
2017-05-29 16:31:54,655 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (10/36) (4b697b61f89480e63d009c50fae0092b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,655 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (10/36) (attempt #0) to splat35
2017-05-29 16:31:54,655 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (11/36) (76c9e632d802f9b4ff8d9fb3ecff2cc4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,655 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (11/36) (attempt #0) to splat35
2017-05-29 16:31:54,656 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (12/36) (33dd774ef026ffa1db61c21b0617f0b3) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,656 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (12/36) (attempt #0) to splat35
2017-05-29 16:31:54,656 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (13/36) (f50ca6a7636a2a4c40659f61c245a65c) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,656 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (13/36) (attempt #0) to splat35
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (14/36) (5101ca6b54ef329068347b9e9cdec266) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (14/36) (attempt #0) to splat35
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (15/36) (4bdd270c9a1cc28b6516d32d4e842cb5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (15/36) (attempt #0) to splat35
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (16/36) (958cff3e247c459a24c0eaa2eda4906e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (16/36) (attempt #0) to splat35
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (17/36) (4e49a3ede0ecb859dfd55edd7673abf5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,660 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (17/36) (attempt #0) to splat36
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (18/36) (2235844f092978a7af2bb4f17f55a0f1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (18/36) (attempt #0) to splat36
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (19/36) (cd213dd124a5159f3fdaea3a1ebe4445) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (19/36) (attempt #0) to splat35
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (20/36) (5773ac2635b81f9fdf08045047846e18) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (20/36) (attempt #0) to splat35
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (21/36) (9d35f93ed023f8445678a10c20a949cd) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,661 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (21/36) (attempt #0) to splat36
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (22/36) (f043ad4c15e9a26b52e986871d93a60b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (22/36) (attempt #0) to splat36
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (23/36) (e69ebebed77492314d29331adbbf44b5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (23/36) (attempt #0) to splat35
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (24/36) (a5e7a24954197cf22ef66d600ae02af2) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (24/36) (attempt #0) to splat35
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (25/36) (3cf95ada57e9294d2ca2d42ee479f125) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (25/36) (attempt #0) to splat36
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (26/36) (dca989a3b3d73f1d8c796ea1f7eb12f4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (26/36) (attempt #0) to splat36
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (27/36) (00ac7e184d35178054e93c114fec3f44) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (27/36) (attempt #0) to splat35
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (28/36) (d99d45e641808cd31a73c4153683a83a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,663 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (28/36) (attempt #0) to splat35
2017-05-29 16:31:54,671 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (29/36) (8929bcffdb86cab2665fa6871c6c533b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,671 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (29/36) (attempt #0) to splat36
2017-05-29 16:31:54,671 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (30/36) (01629d9756db1dfc6f2f2b8168f168ec) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,671 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (30/36) (attempt #0) to splat36
2017-05-29 16:31:54,672 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (31/36) (982f901aaea1c4cc1bdad35b373d8532) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (31/36) (attempt #0) to splat35
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (32/36) (9fe73b3df4aebe808acfe6ae461e0732) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (32/36) (attempt #0) to splat35
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (33/36) (960b53efedf89bb595b306529f3a6151) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (33/36) (attempt #0) to splat36
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (34/36) (b928ad62f15f4e480ae6bb63babf6934) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (34/36) (attempt #0) to splat36
2017-05-29 16:31:54,675 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (35/36) (16db490845c6f95595d60739247ea7c0) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (35/36) (attempt #0) to splat35
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (36/36) (62f6668f7c86c13b8f02f36ae781a91a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (36/36) (attempt #0) to splat35
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (1/36) (44401fe510e235e35c1ba1578d8e6b33) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (1/36) (attempt #0) to splat36
2017-05-29 16:31:54,676 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (2/36) (28d093e9852b9b952cd921d445114ca6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (2/36) (attempt #0) to splat36
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (3/36) (407abb38798cf7d70c055c816a19c983) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (3/36) (attempt #0) to splat36
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (4/36) (27b3bd4a778f1f41ce445c8b7c31150b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (4/36) (attempt #0) to splat36
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (5/36) (99ec69005a750402e77bbd1decde4c35) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (5/36) (attempt #0) to splat36
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (6/36) (eb713d1f5142545c580b25eaa68e782d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,677 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (6/36) (attempt #0) to splat36
2017-05-29 16:31:54,678 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (7/36) (9f1300cea6876924d4e7d7a8668a60cf) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,678 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (7/36) (attempt #0) to splat36
2017-05-29 16:31:54,678 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (8/36) (f219ec1b234c8443dded488cefe42f30) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,678 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (8/36) (attempt #0) to splat36
2017-05-29 16:31:54,678 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (9/36) (4745607473b65f37cdf4d0d73086e016) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (9/36) (attempt #0) to splat36
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (10/36) (efda312f6d3e099210866747acd1867b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (10/36) (attempt #0) to splat36
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (11/36) (f0017c027796177a91346da4e9685e0e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (11/36) (attempt #0) to splat36
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (12/36) (01fa118aa297202828f48d371625adb1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (12/36) (attempt #0) to splat36
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (13/36) (49de6dc924cd8c694607a34af05479fc) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,679 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (13/36) (attempt #0) to splat36
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (14/36) (e20140a11782b5204b42bdb1ad9f07b9) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (14/36) (attempt #0) to splat36
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (15/36) (a622865a465b51c22bcb2740c45b2e66) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (15/36) (attempt #0) to splat36
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (16/36) (69ff3020d1e536d898978451911e7ab6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (16/36) (attempt #0) to splat36
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (17/36) (15fd5c8635ae6481ad47ff422cc42110) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,680 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (17/36) (attempt #0) to splat36
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (18/36) (faf71ffcfbbf64ed6a2784f1414ec00e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (18/36) (attempt #0) to splat36
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (19/36) (0c65dd5f0892fae3716811454f4ff300) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (19/36) (attempt #0) to splat35
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (20/36) (96702e65f3e5203c6dec0ba6a0bfb467) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (20/36) (attempt #0) to splat35
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (21/36) (739c5c3453f35465422eb384196d907a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (21/36) (attempt #0) to splat35
2017-05-29 16:31:54,681 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (22/36) (bc2967cd3a083ae19e1d9ccd3075a7a4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (22/36) (attempt #0) to splat35
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (23/36) (6750a298606c89c5e2f53c76a1638103) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (23/36) (attempt #0) to splat35
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (24/36) (5cf1d6e1b317483b4c7284fbceecaceb) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (24/36) (attempt #0) to splat35
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (25/36) (046c0059edb75cff2eeb92d9646d3761) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (25/36) (attempt #0) to splat35
2017-05-29 16:31:54,682 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (26/36) (73a4949602f06ce5ba21690e7e8feaa1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (26/36) (attempt #0) to splat35
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (27/36) (ff7f5b8ce1e5095118dcbda086cc6199) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (27/36) (attempt #0) to splat35
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (28/36) (1548d81bf8682ebdf5a7d61af8a4ea6b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (28/36) (attempt #0) to splat35
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (29/36) (f2d5408081701337653774097ace38ef) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (29/36) (attempt #0) to splat35
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (30/36) (095606e348a444e0f754d17c11aae92e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,683 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (30/36) (attempt #0) to splat35
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (31/36) (9527f1c80d21186e375aad89b3c4d1e8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (31/36) (attempt #0) to splat35
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (32/36) (3b1bc49c16ca67aa359768ca342e270f) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (32/36) (attempt #0) to splat35
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (33/36) (49fb7830e2c79ff3cb2631dc49f46c4a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (33/36) (attempt #0) to splat35
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (34/36) (954e033a050320ba2a1141df770f3773) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,684 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (34/36) (attempt #0) to splat35
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (35/36) (bc9bb2ce7dc6ea04f3cf28f8b474c319) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (35/36) (attempt #0) to splat35
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (36/36) (18b512eacbd09aeb806d2ad3143e50ff) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Window aggregator (36/36) (attempt #0) to splat35
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (1/36) (76be66f0f476c01d38f8ab19fe065c9b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,685 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (1/36) (attempt #0) to splat36
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (2/36) (3f01b22294b9725be7f9a9ff44ea9d98) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (2/36) (attempt #0) to splat36
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (3/36) (a3c95029cf5844fbab1050b819dbda54) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (3/36) (attempt #0) to splat36
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (4/36) (fac51d9095478467c1078dfcc8258a63) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (4/36) (attempt #0) to splat36
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (5/36) (71bc304a571ec49cc7eec28b3d57490a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,686 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (5/36) (attempt #0) to splat36
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (6/36) (e58d2026a75abfac1f0c7da498fa17c5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (6/36) (attempt #0) to splat36
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (7/36) (c0bedf61b68c843c08bc498e63bb70c1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (7/36) (attempt #0) to splat36
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (8/36) (6d242314dbcff407d889880f98f82962) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (8/36) (attempt #0) to splat36
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (9/36) (12535bc28d239259f2195ef860d124bf) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,687 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (9/36) (attempt #0) to splat36
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (10/36) (10f53dce447ba2949db5b4973433d621) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (10/36) (attempt #0) to splat36
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (11/36) (e92bd9fdcfaa96afbf8b3c4327809388) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (11/36) (attempt #0) to splat36
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (12/36) (009446007278cdb24eec92d443b8b826) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (12/36) (attempt #0) to splat36
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (13/36) (0aa4d4e41385a23b032c6b27295e96e1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (13/36) (attempt #0) to splat36
2017-05-29 16:31:54,688 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (14/36) (ac69df9f65cbc8fc0be0ca9eb3713cd5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (14/36) (attempt #0) to splat36
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (15/36) (52e31d86a1e2ff3ad2a1559ef42e03d0) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (15/36) (attempt #0) to splat36
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (16/36) (19838cd9eb590950b492ac10b081f4d5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (16/36) (attempt #0) to splat36
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (17/36) (0c95eb36efbc012a5a50d5e27254fa9a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (17/36) (attempt #0) to splat36
2017-05-29 16:31:54,689 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (18/36) (0987be21a62ff4cad50abf836518e409) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (18/36) (attempt #0) to splat36
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (19/36) (fd5ceb8557a9d4c7efe0c66a734636c2) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (19/36) (attempt #0) to splat35
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (20/36) (47cde22a4129b2c934d8558e86b0d198) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (20/36) (attempt #0) to splat35
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (21/36) (97d25242328e500efcf691ef60de5f10) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (21/36) (attempt #0) to splat35
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (22/36) (ac9a75e085dbfbe88354170d3bc897e5) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,690 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (22/36) (attempt #0) to splat35
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (23/36) (0438e97eac10c23d5b3bc36c46b55587) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (23/36) (attempt #0) to splat35
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (24/36) (a77f147855dfea06d9a695161e0e7497) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (24/36) (attempt #0) to splat35
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (25/36) (f0ce218cefeec3d0faa696179063876c) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (25/36) (attempt #0) to splat35
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (26/36) (61de8760c36cc83e0b92d9035dff5891) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (26/36) (attempt #0) to splat35
2017-05-29 16:31:54,691 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (27/36) (5ac020fc8d210684eb06856d23bb3d44) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (27/36) (attempt #0) to splat35
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (28/36) (ca94d64cc646e2ee0004f46e4cfa37f9) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (28/36) (attempt #0) to splat35
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (29/36) (c0c7d4a12bd4255721d4dd23bbf5ead6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (29/36) (attempt #0) to splat35
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (30/36) (1bc3572d4a0257b28a64912ed2c75a34) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (30/36) (attempt #0) to splat35
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (31/36) (7066ff88f335748595494934aad57f24) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,692 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (31/36) (attempt #0) to splat35
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (32/36) (abc0be309299e5697dab815e9393a9e7) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (32/36) (attempt #0) to splat35
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (33/36) (deca4b063c13d18c85b265da64b9b475) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (33/36) (attempt #0) to splat35
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (34/36) (1a2d2dcb3459bc2ef2404f57cb6004f8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (34/36) (attempt #0) to splat35
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (35/36) (3e4f56a96d5473270e124f8c7ca9604e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (35/36) (attempt #0) to splat35
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (36/36) (2a2a46ab1c1e4d60f794cdb123e48c8a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,693 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Keep last -> Create Aggrigato events (36/36) (attempt #0) to splat35
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (1/36) (c8be9d9dca6bf58e6e90f5de2c169032) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (1/36) (attempt #0) to splat36
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (2/36) (3dca5be4e289fd53f6c7dd3b0bedd9e9) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (2/36) (attempt #0) to splat36
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (3/36) (f8c6c1e96facb565e37d8e88f9f13b7d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (3/36) (attempt #0) to splat36
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (4/36) (51f5859e32efafdc1f9db0bfe506fa7e) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,694 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (4/36) (attempt #0) to splat36
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (5/36) (03b5306f5633c5a7658144d6bc3be816) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (5/36) (attempt #0) to splat36
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (6/36) (1b96d9676032e349ba9db9d14761b227) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (6/36) (attempt #0) to splat36
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (7/36) (206a879febc2f8d85ef183091d6329a6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (7/36) (attempt #0) to splat36
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (8/36) (9235c8f0bdc2a9385b8a9cbec7b07a37) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (8/36) (attempt #0) to splat36
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (9/36) (587248d3bae79493b497aae1c1448f0a) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,695 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (9/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (10/36) (5a487394fbdf5a1d44549e1fd8c020f6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (10/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (11/36) (97fc71c1fa29ad06a3100b2c292e29d4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (11/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (12/36) (34b207cf0e0318c09fbea04eb178b91d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (12/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (13/36) (0846260854e550737a566531e0a465c7) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (13/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (14/36) (6a8334bc93cb25bec7bbb0eac1d3d95d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (14/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (15/36) (dfa768a7d7cb82af0ca60245d81c305d) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (15/36) (attempt #0) to splat36
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (16/36) (5a52aba1ee00030543cb2654f4962bd7) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,696 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (16/36) (attempt #0) to splat36
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (17/36) (acbbe587584908a5aa13593b22177043) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (17/36) (attempt #0) to splat36
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (18/36) (12c3b167129a675bfbd94d3526da4da3) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (18/36) (attempt #0) to splat36
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (19/36) (145ccaef535103d25e8543e98e51ccda) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (19/36) (attempt #0) to splat35
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (20/36) (4410c015d3e301d6446aa5f3e1bafe4b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (20/36) (attempt #0) to splat35
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (21/36) (0461b30c1d495dc8dbf3c4adddebc5b6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (21/36) (attempt #0) to splat35
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (22/36) (c8b0385fa80b0d62e917b2417daa9f4f) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (22/36) (attempt #0) to splat35
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (23/36) (7f5e9d70521703ae07125be982c21a20) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (23/36) (attempt #0) to splat35
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (24/36) (936923160fdbb441329f528e6a4603a1) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,697 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (24/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (25/36) (5fd4f890c187f1bc80cbed800b5f8095) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (25/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (26/36) (f76e02b1845a43841615b39160b08f28) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (26/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (27/36) (c38dbb4799990ec1c33636598436ae47) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (27/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (28/36) (fd53b4cd547f2e9542f5cbc5c9c7a63f) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (28/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (29/36) (3a128e524d55d79e7ce2d1e33612ae99) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (29/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (30/36) (cdfa63a8155de2afa61b68e99cbb6d35) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (30/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (31/36) (537c05cfac4fdacac1b3cf8c40eb8aa6) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (31/36) (attempt #0) to splat35
2017-05-29 16:31:54,698 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (32/36) (2abe87a6385b6a622febcd7f6ddad7cd) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (32/36) (attempt #0) to splat35
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (33/36) (c70aeac8cbec03cf6c99d849a18d40b9) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (33/36) (attempt #0) to splat35
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (34/36) (7087f8cd0451e1123c32de4d50a108be) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (34/36) (attempt #0) to splat35
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (35/36) (1b4294a4c903b6caa9e1e41437bf0bd4) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (35/36) (attempt #0) to splat35
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (36/36) (c18d104a8fbeb676e27adfdc93520132) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying MySql output info -> Filter (36/36) (attempt #0) to splat35
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - To DeploymentInfo (1/1) (78c698d484b0bdae61acda7f7ab6bd59) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,699 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying To DeploymentInfo (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,700 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSink-14 (1/1) (837a52b20597bbed15f87f6861d8fb2b) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,700 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying IterationSink-14 (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,700 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Job information (1/1) (9186549a923997f17ea98e8090f252a8) switched from SCHEDULED to DEPLOYING.
2017-05-29 16:31:54,700 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Create Job information (1/1) (attempt #0) to splat36
2017-05-29 16:31:54,743 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (13/16) (40279c4460e29f4a78986c2907c18054) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,743 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (4/16) (43a56629af2a4649c7df995ac36fefc0) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,743 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (15/16) (0c6aabbd3021cfd55a674acf51941f46) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,743 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (8/16) (b771f711bd07ade12529a4d68c13fb46) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,744 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (16/16) (83731e3d7103653b18bf834ba586eee6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,744 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (12/16) (d2d1e23fc1aaaae5772078e4c01680f1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,744 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (14/16) (caeaccf1e2f1b3b97055df8023966971) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,745 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (16/16) (7a34a4e3f0158df8d1146c00938f70d4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,760 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (10/16) (1c6c68f2fb9c8bbca854589a29fb8037) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,760 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (11/16) (d4fc1458663bef5abc14ffa3e468b900) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,761 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (9/16) (fcb900b390c2129333f9f4dc46f27e6b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,761 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (13/36) (f50ca6a7636a2a4c40659f61c245a65c) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,761 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (12/16) (3b6eb45c2df4bf448a81ee65f54b041f) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,761 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (14/36) (5101ca6b54ef329068347b9e9cdec266) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,761 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (7/16) (251c2f30392170e8c292641e0a9b426b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,762 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (15/16) (62cf334d17489347c0924db1abbc4b77) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,762 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (15/36) (4bdd270c9a1cc28b6516d32d4e842cb5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,762 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (11/16) (7c30ce46569a08f3507cc2d59369a1b8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,763 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (3/16) (666ab64b86256506544ade559a82768f) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,763 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (16/36) (958cff3e247c459a24c0eaa2eda4906e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,763 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (14/16) (6b9501d41365171fc6703d495049bbf8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,764 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (20/36) (5773ac2635b81f9fdf08045047846e18) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,764 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (8/16) (5ab0d6c2db131583fcb286445edc4056) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,764 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (6/16) (5178b5d53cb97b1e403e01bb2b817d19) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,765 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (10/16) (c5faff50451445af12c178068acfd72d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,765 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (6/16) (1459b81d9737aa3d74b4f7ca3bac7a55) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,766 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (7/16) (18b748bc5ceafb2b72db8883521c0cab) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,766 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (2/16) (3a7a60de0477d9846e9cee9c631c9996) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,767 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (5/16) (36c901cd588e6b009ede5451417eedf1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,767 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (5/36) (27a923385cd466c822ec2f87e0f2dee8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,768 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (6/36) (082bd2f368345469425518c68dcdb3ff) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,769 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (7/36) (85ed2703a6105bdaaa48418f6330b332) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,769 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (8/36) (4a2d301a96da9e76fd136c786c192da7) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,775 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (9/16) (856e71bb3569fe18e2b763756798e184) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,776 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (1/16) (06832d91c00ac69b4546b9b3811e0282) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,776 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSource-14 (1/1) (70221cffeb826034ea276ca7674b2436) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,776 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (13/16) (f7158fd780127babf1c4f065da9a38a5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,777 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (1/16) (b0a334064879afab6b121fc19932a7bc) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,777 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[event.rakdos.log] -> Wrap events (5/16) (927a9a263139fa0b44691a26defe9730) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,777 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (3/16) (14b7bd967ab6a3941cffef0f7bff1ef8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,777 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (2/16) (acff65ec4d15e1572a9cc1474ed673a2) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,777 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbea.state.event.rakdos.log] -> Timestamp assigner -> Filter state updates -> Wrap events (4/16) (b12985913bfc18cef974b5d349cee750) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,778 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Query Job Info (1/1) (0e4da403b5f49e1084222901df4aced2) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,778 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: Kafka[rbeaDeploymentsplattest1] -> Max watermark -> Drop errors -> Filter for topic (1/1) (e092f6977d7f38ed0e76183a68753b53) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,778 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Fields and Ids -> Filter Errors and Notifications (1/1) (e10212e1c24c0d87375600dd2a1ff89d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,779 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (1/36) (051a748fa704f2d2da94e2a990277a8d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,779 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (24/36) (a5e7a24954197cf22ef66d600ae02af2) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,780 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (28/36) (d99d45e641808cd31a73c4153683a83a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,780 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (22/36) (f043ad4c15e9a26b52e986871d93a60b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,780 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (18/36) (2235844f092978a7af2bb4f17f55a0f1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,785 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (2/36) (1dc64cde096addda807f32c2649f41a2) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,786 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (3/36) (bd1ad53e204ec9bde667ea7edbed6ebf) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,787 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (26/36) (dca989a3b3d73f1d8c796ea1f7eb12f4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,787 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (30/36) (01629d9756db1dfc6f2f2b8168f168ec) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,796 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (9/36) (be858d29b9f44edb994e345b123f07c3) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,797 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (10/36) (4b697b61f89480e63d009c50fae0092b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,797 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (11/36) (76c9e632d802f9b4ff8d9fb3ecff2cc4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,798 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (12/36) (33dd774ef026ffa1db61c21b0617f0b3) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,805 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (19/36) (cd213dd124a5159f3fdaea3a1ebe4445) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,805 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (23/36) (e69ebebed77492314d29331adbbf44b5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,806 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (27/36) (00ac7e184d35178054e93c114fec3f44) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,806 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (4/36) (8c22856121dab2d820a70b77d806260a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,809 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (34/36) (b928ad62f15f4e480ae6bb63babf6934) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,810 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (17/36) (4e49a3ede0ecb859dfd55edd7673abf5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,846 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (32/36) (9fe73b3df4aebe808acfe6ae461e0732) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,858 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (31/36) (982f901aaea1c4cc1bdad35b373d8532) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,858 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (35/36) (16db490845c6f95595d60739247ea7c0) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,858 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (21/36) (9d35f93ed023f8445678a10c20a949cd) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,860 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (36/36) (62f6668f7c86c13b8f02f36ae781a91a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,860 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (28/36) (1548d81bf8682ebdf5a7d61af8a4ea6b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,863 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (10/36) (efda312f6d3e099210866747acd1867b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,863 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (30/36) (095606e348a444e0f754d17c11aae92e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,863 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (11/36) (f0017c027796177a91346da4e9685e0e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,863 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (29/36) (f2d5408081701337653774097ace38ef) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,866 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (20/36) (96702e65f3e5203c6dec0ba6a0bfb467) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,866 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (19/36) (0c65dd5f0892fae3716811454f4ff300) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,867 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (21/36) (739c5c3453f35465422eb384196d907a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,867 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (22/36) (bc2967cd3a083ae19e1d9ccd3075a7a4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,867 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (25/36) (3cf95ada57e9294d2ca2d42ee479f125) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,868 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (29/36) (8929bcffdb86cab2665fa6871c6c533b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,868 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (23/36) (6750a298606c89c5e2f53c76a1638103) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,868 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Execute processors -> (Filter processor info -> Filter Failures, Filter BEA) (33/36) (960b53efedf89bb595b306529f3a6151) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,869 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (12/36) (01fa118aa297202828f48d371625adb1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,869 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (24/36) (5cf1d6e1b317483b4c7284fbceecaceb) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,870 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (25/36) (046c0059edb75cff2eeb92d9646d3761) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,870 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (31/36) (9527f1c80d21186e375aad89b3c4d1e8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,871 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (32/36) (3b1bc49c16ca67aa359768ca342e270f) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,871 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (33/36) (49fb7830e2c79ff3cb2631dc49f46c4a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,875 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (26/36) (73a4949602f06ce5ba21690e7e8feaa1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,883 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (34/36) (954e033a050320ba2a1141df770f3773) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,885 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (35/36) (bc9bb2ce7dc6ea04f3cf28f8b474c319) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,888 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (27/36) (ff7f5b8ce1e5095118dcbda086cc6199) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,890 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (2/36) (28d093e9852b9b952cd921d445114ca6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,891 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (19/36) (fd5ceb8557a9d4c7efe0c66a734636c2) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,891 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (36/36) (18b512eacbd09aeb806d2ad3143e50ff) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,892 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (1/36) (44401fe510e235e35c1ba1578d8e6b33) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,892 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (13/36) (49de6dc924cd8c694607a34af05479fc) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,893 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (20/36) (47cde22a4129b2c934d8558e86b0d198) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,897 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (28/36) (ca94d64cc646e2ee0004f46e4cfa37f9) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,901 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (21/36) (97d25242328e500efcf691ef60de5f10) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,903 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (29/36) (c0c7d4a12bd4255721d4dd23bbf5ead6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,908 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (3/36) (407abb38798cf7d70c055c816a19c983) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,910 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (14/36) (e20140a11782b5204b42bdb1ad9f07b9) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,913 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (15/36) (a622865a465b51c22bcb2740c45b2e66) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,913 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (4/36) (27b3bd4a778f1f41ce445c8b7c31150b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,914 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (5/36) (99ec69005a750402e77bbd1decde4c35) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,916 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (18/36) (faf71ffcfbbf64ed6a2784f1414ec00e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,916 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (22/36) (ac9a75e085dbfbe88354170d3bc897e5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,917 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (23/36) (0438e97eac10c23d5b3bc36c46b55587) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,921 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (6/36) (eb713d1f5142545c580b25eaa68e782d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,922 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (17/36) (15fd5c8635ae6481ad47ff422cc42110) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,929 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (16/36) (69ff3020d1e536d898978451911e7ab6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (25/36) (f0ce218cefeec3d0faa696179063876c) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (30/36) (1bc3572d4a0257b28a64912ed2c75a34) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,931 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (31/36) (7066ff88f335748595494934aad57f24) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,933 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (24/36) (a77f147855dfea06d9a695161e0e7497) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,935 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (32/36) (abc0be309299e5697dab815e9393a9e7) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (34/36) (1a2d2dcb3459bc2ef2404f57cb6004f8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (26/36) (61de8760c36cc83e0b92d9035dff5891) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (33/36) (deca4b063c13d18c85b265da64b9b475) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (27/36) (5ac020fc8d210684eb06856d23bb3d44) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,940 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (11/36) (e92bd9fdcfaa96afbf8b3c4327809388) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,941 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (12/36) (009446007278cdb24eec92d443b8b826) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,941 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (10/36) (10f53dce447ba2949db5b4973433d621) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,942 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (13/36) (0aa4d4e41385a23b032c6b27295e96e1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,948 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (19/36) (145ccaef535103d25e8543e98e51ccda) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,952 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (7/36) (9f1300cea6876924d4e7d7a8668a60cf) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,956 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (14/36) (ac69df9f65cbc8fc0be0ca9eb3713cd5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,956 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (29/36) (3a128e524d55d79e7ce2d1e33612ae99) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,956 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (36/36) (2a2a46ab1c1e4d60f794cdb123e48c8a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,962 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (35/36) (3e4f56a96d5473270e124f8c7ca9604e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,962 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (30/36) (cdfa63a8155de2afa61b68e99cbb6d35) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,963 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (8/36) (f219ec1b234c8443dded488cefe42f30) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,964 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (1/36) (76be66f0f476c01d38f8ab19fe065c9b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,967 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (2/36) (3f01b22294b9725be7f9a9ff44ea9d98) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,968 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Window aggregator (9/36) (4745607473b65f37cdf4d0d73086e016) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,970 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (3/36) (a3c95029cf5844fbab1050b819dbda54) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,970 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (20/36) (4410c015d3e301d6446aa5f3e1bafe4b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,971 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (4/36) (fac51d9095478467c1078dfcc8258a63) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,972 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (16/36) (19838cd9eb590950b492ac10b081f4d5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,972 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (15/36) (52e31d86a1e2ff3ad2a1559ef42e03d0) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,975 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (28/36) (fd53b4cd547f2e9542f5cbc5c9c7a63f) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,976 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (21/36) (0461b30c1d495dc8dbf3c4adddebc5b6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,978 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (31/36) (537c05cfac4fdacac1b3cf8c40eb8aa6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,980 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (22/36) (c8b0385fa80b0d62e917b2417daa9f4f) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,980 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (5/36) (71bc304a571ec49cc7eec28b3d57490a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,982 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (23/36) (7f5e9d70521703ae07125be982c21a20) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,989 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (24/36) (936923160fdbb441329f528e6a4603a1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,990 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (25/36) (5fd4f890c187f1bc80cbed800b5f8095) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,991 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (32/36) (2abe87a6385b6a622febcd7f6ddad7cd) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,992 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (26/36) (f76e02b1845a43841615b39160b08f28) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,992 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (33/36) (c70aeac8cbec03cf6c99d849a18d40b9) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,992 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (27/36) (c38dbb4799990ec1c33636598436ae47) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,992 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (34/36) (7087f8cd0451e1123c32de4d50a108be) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,993 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (36/36) (c18d104a8fbeb676e27adfdc93520132) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,993 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (35/36) (1b4294a4c903b6caa9e1e41437bf0bd4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,998 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (17/36) (0c95eb36efbc012a5a50d5e27254fa9a) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,998 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (18/36) (0987be21a62ff4cad50abf836518e409) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:54,999 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (10/36) (5a487394fbdf5a1d44549e1fd8c020f6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,003 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (11/36) (97fc71c1fa29ad06a3100b2c292e29d4) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,003 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (13/36) (0846260854e550737a566531e0a465c7) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,004 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (12/36) (34b207cf0e0318c09fbea04eb178b91d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,004 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (14/36) (6a8334bc93cb25bec7bbb0eac1d3d95d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,004 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (15/36) (dfa768a7d7cb82af0ca60245d81c305d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,006 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (16/36) (5a52aba1ee00030543cb2654f4962bd7) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,006 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (18/36) (12c3b167129a675bfbd94d3526da4da3) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,006 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (17/36) (acbbe587584908a5aa13593b22177043) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,033 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (6/36) (e58d2026a75abfac1f0c7da498fa17c5) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,063 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (9/36) (12535bc28d239259f2195ef860d124bf) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,076 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (8/36) (6d242314dbcff407d889880f98f82962) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,078 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Keep last -> Create Aggrigato events (7/36) (c0bedf61b68c843c08bc498e63bb70c1) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,084 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (1/36) (c8be9d9dca6bf58e6e90f5de2c169032) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,096 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (2/36) (3dca5be4e289fd53f6c7dd3b0bedd9e9) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,096 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (3/36) (f8c6c1e96facb565e37d8e88f9f13b7d) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,097 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (4/36) (51f5859e32efafdc1f9db0bfe506fa7e) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,098 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (5/36) (03b5306f5633c5a7658144d6bc3be816) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,102 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (6/36) (1b96d9676032e349ba9db9d14761b227) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,146 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (7/36) (206a879febc2f8d85ef183091d6329a6) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,165 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (8/36) (9235c8f0bdc2a9385b8a9cbec7b07a37) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,166 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - To DeploymentInfo (1/1) (78c698d484b0bdae61acda7f7ab6bd59) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,166 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - IterationSink-14 (1/1) (837a52b20597bbed15f87f6861d8fb2b) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,166 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Create Job information (1/1) (9186549a923997f17ea98e8090f252a8) switched from DEPLOYING to RUNNING.
2017-05-29 16:31:55,177 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - MySql output info -> Filter (9/36) (587248d3bae79493b497aae1c1448f0a) switched from DEPLOYING to RUNNING.
2017-05-29 16:33:47,887 INFO org.apache.flink.yarn.YarnJobManager - Attempting to recover all jobs.
2017-05-29 16:33:47,890 INFO org.apache.flink.yarn.YarnJobManager - There are 1 jobs to recover. Starting the job recovery.
2017-05-29 16:33:47,892 INFO org.apache.flink.yarn.YarnJobManager - Attempting to recover job 28818562367ba62e35b88fb45983bb52.
2017-05-29 16:33:47,904 INFO org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore - Recovered SubmittedJobGraph(28818562367ba62e35b88fb45983bb52, JobInfo(clients: Set((Actor[akka.tcp://flink@deploy.sto.midasplayer.com:37019/temp/$F],DETACHED)), start: 1496068314091)).
2017-05-29 16:33:47,905 INFO org.apache.flink.yarn.YarnJobManager - Ignoring job recovery for 28818562367ba62e35b88fb45983bb52, because it is already submitted.
2017-05-29 16:33:54,574 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 3204 @ 1496068434563
2017-05-29 16:38:06,069 ERROR org.apache.flink.yarn.YarnJobManager - Error in CheckpointCoordinator while processing Confirm Task Checkpoint 3204 for (28818562367ba62e35b88fb45983bb52/f043ad4c15e9a26b52e986871d93a60b) - state=SubtaskState{chainedStateHandle=org.apache.flink.runtime.state.ChainedStateHandle@e1781, operatorStateFromBackend=org.apache.flink.runtime.state.ChainedStateHandle@fe3a4ba6, operatorStateFromStream=org.apache.flink.runtime.state.ChainedStateHandle@e1781, keyedStateFromBackend=org.apache.flink.runtime.state.IncrementalKeyedStateHandle@7878a000, keyedStateFromStream=KeyGroupsStateHandle{groupRangeOffsets=KeyGroupRangeOffsets{keyGroupRange=KeyGroupRange{startKeyGroup=75, endKeyGroup=78}, offsets=[0, 1496489, 2987283, 4488005]}, data=File State: hdfs://splatnameservice/flink/checkpoints/event.rakdos.log/28818562367ba62e35b88fb45983bb52/chk-3204/6a4578ac-b4bc-43f2-9fcb-aade521f6e87 [5986483 bytes]}, stateSize=2574110631}
org.apache.flink.runtime.checkpoint.CheckpointException: Could not finalize the pending checkpoint 3204.
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:861)
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveAcknowledgeMessage(CheckpointCoordinator.java:776)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply$mcV$sp(JobManager.scala:1462)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply(JobManager.scala:1461)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply(JobManager.scala:1461)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.io.IOException: Unknown implementation of StreamStateHandle: class org.apache.flink.runtime.state.PlaceholderStreamStateHandle
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeStreamStateHandle(SavepointV2Serializer.java:484)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeStreamStateHandleMap(SavepointV2Serializer.java:342)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeKeyedStateHandle(SavepointV2Serializer.java:329)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeSubtaskState(SavepointV2Serializer.java:270)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serialize(SavepointV2Serializer.java:122)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serialize(SavepointV2Serializer.java:66)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointStore.storeSavepointToHandle(SavepointStore.java:199)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointStore.storeExternalizedCheckpointToHandle(SavepointStore.java:164)
at org.apache.flink.runtime.checkpoint.PendingCheckpoint.finalizeCheckpointExternalized(PendingCheckpoint.java:286)
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:851)
... 12 more
2017-05-29 16:38:06,070 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 3205 @ 1496068686067
2017-05-29 16:38:17,707 INFO org.apache.flink.runtime.blob.BlobCache - Created BLOB cache storage directory /tmp/blobStore-65768b00-b3a7-4830-924c-159f584aac69
2017-05-29 16:39:20,099 ERROR org.apache.flink.yarn.YarnJobManager - Error in CheckpointCoordinator while processing Confirm Task Checkpoint 3205 for (28818562367ba62e35b88fb45983bb52/a5e7a24954197cf22ef66d600ae02af2) - state=SubtaskState{chainedStateHandle=org.apache.flink.runtime.state.ChainedStateHandle@e1781, operatorStateFromBackend=org.apache.flink.runtime.state.ChainedStateHandle@5ec8ba87, operatorStateFromStream=org.apache.flink.runtime.state.ChainedStateHandle@e1781, keyedStateFromBackend=org.apache.flink.runtime.state.IncrementalKeyedStateHandle@f25ac54, keyedStateFromStream=KeyGroupsStateHandle{groupRangeOffsets=KeyGroupRangeOffsets{keyGroupRange=KeyGroupRange{startKeyGroup=82, endKeyGroup=85}, offsets=[0, 1503085, 2999319, 4493581]}, data=File State: hdfs://splatnameservice/flink/checkpoints/event.rakdos.log/28818562367ba62e35b88fb45983bb52/chk-3205/c58bdad5-3fa9-4ef1-aefa-d7752c9bc357 [5977745 bytes]}, stateSize=2599010034}
org.apache.flink.runtime.checkpoint.CheckpointException: Could not finalize the pending checkpoint 3205.
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:861)
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.receiveAcknowledgeMessage(CheckpointCoordinator.java:776)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply$mcV$sp(JobManager.scala:1462)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply(JobManager.scala:1461)
at org.apache.flink.runtime.jobmanager.JobManager$$anonfun$org$apache$flink$runtime$jobmanager$JobManager$$handleCheckpointMessage$1.apply(JobManager.scala:1461)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
Caused by: java.io.IOException: Unknown implementation of StreamStateHandle: class org.apache.flink.runtime.state.PlaceholderStreamStateHandle
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeStreamStateHandle(SavepointV2Serializer.java:484)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeStreamStateHandleMap(SavepointV2Serializer.java:342)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeKeyedStateHandle(SavepointV2Serializer.java:329)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serializeSubtaskState(SavepointV2Serializer.java:270)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serialize(SavepointV2Serializer.java:122)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointV2Serializer.serialize(SavepointV2Serializer.java:66)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointStore.storeSavepointToHandle(SavepointStore.java:199)
at org.apache.flink.runtime.checkpoint.savepoint.SavepointStore.storeExternalizedCheckpointToHandle(SavepointStore.java:164)
at org.apache.flink.runtime.checkpoint.PendingCheckpoint.finalizeCheckpointExternalized(PendingCheckpoint.java:286)
at org.apache.flink.runtime.checkpoint.CheckpointCoordinator.completePendingCheckpoint(CheckpointCoordinator.java:851)
... 12 more
2017-05-29 16:40:06,070 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 3206 @ 1496068806067
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment