2018-09-17 15:22:13,986 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- 2018-09-17 15:22:13,987 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting YarnSessionClusterEntrypoint (Version: 1.5.2, Rev:, Date:) 2018-09-17 15:22:13,987 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - OS current user: yarn 2018-09-17 15:22:14,387 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Current Hadoop/Kerberos user: hadoop 2018-09-17 15:22:14,387 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM: OpenJDK 64-Bit Server VM - Oracle Corporation - 1.8/25.181-b13 2018-09-17 15:22:14,387 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Maximum heap size: 5397 MiBytes 2018-09-17 15:22:14,387 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JAVA_HOME: /usr/lib/jvm/java-openjdk 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Hadoop version: 2.8.4-amzn-1 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - JVM Options: 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Xmx6072m 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlog.file=/var/log/hadoop-yarn/containers/application_1537197527300_0001/container_1537197527300_0001_01_000001/jobmanager.log 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -Dlog4j.configuration=file:log4j.properties 2018-09-17 15:22:14,388 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Program Arguments: (none) 2018-09-17 15:22:14,389 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Classpath: lib/flink-python_2.11-1.5.2.jar:lib/flink-shaded-hadoop2-uber-1.5.2.jar:lib/log4j-1.2.17.jar:lib/slf4j-log4j12-1.7.7.jar:log4j.properties:flink.jar:flink-conf.yaml::/etc/hadoop/conf:/usr/lib/hadoop/hadoop-extras-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-archive-logs.jar:/usr/lib/hadoop/hadoop-auth.jar:/usr/lib/hadoop/hadoop-archive-logs-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-annotations.jar:/usr/lib/hadoop/hadoop-distcp-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-streaming.jar:/usr/lib/hadoop/hadoop-distcp.jar:/usr/lib/hadoop/hadoop-common-2.8.4-amzn-1-tests.jar:/usr/lib/hadoop/hadoop-archives.jar:/usr/lib/hadoop/hadoop-ant.jar:/usr/lib/hadoop/hadoop-azure-datalake-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-aws.jar:/usr/lib/hadoop/hadoop-datajoin-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-ant-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-sls-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-rumen.jar:/usr/lib/hadoop/hadoop-openstack-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-azure-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-openstack.jar:/usr/lib/hadoop/hadoop-azure.jar:/usr/lib/hadoop/hadoop-extras.jar:/usr/lib/hadoop/hadoop-azure-datalake.jar:/usr/lib/hadoop/hadoop-gridmix.jar:/usr/lib/hadoop/hadoop-nfs.jar:/usr/lib/hadoop/hadoop-archives-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-datajoin.jar:/usr/lib/hadoop/hadoop-gridmix-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-rumen-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-sls.jar:/usr/lib/hadoop/hadoop-common-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-nfs-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-common.jar:/usr/lib/hadoop/hadoop-auth-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-streaming-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-aws-2.8.4-amzn-1.jar:/usr/lib/hadoop/hadoop-annotations-2.8.4-amzn-1.jar:/usr/lib/hadoop/lib/curator-framework-2.7.1.jar:/usr/lib/hadoop/lib/curator-recipes-2.7.1.jar:/usr/lib/hadoop/lib/commons-beanutils-1.7.0.jar:/usr/lib/hadoop/lib/paranamer-2.3.jar:/usr/lib/hadoop/lib/jettison-1.1.jar:/usr/lib/hadoop/lib/java-xmlbuilder-0.4.jar:/usr/lib/hadoop/lib/jersey-core-1.9.jar:/usr/lib/hadoop/lib/jcip-annotations-1.0-1.jar:/usr/lib/hadoop/lib/jets3t-0.9.0.jar:/usr/lib/hadoop/lib/jackson-core-asl-1.9.13.jar:/usr/lib/hadoop/lib/audience-annotations-0.5.0.jar:/usr/lib/hadoop/lib/junit-4.11.jar:/usr/lib/hadoop/lib/jersey-json-1.9.jar:/usr/lib/hadoop/lib/commons-math3-3.1.1.jar:/usr/lib/hadoop/lib/nimbus-jose-jwt-4.41.1.jar:/usr/lib/hadoop/lib/avro-1.7.4.jar:/usr/lib/hadoop/lib/servlet-api-2.5.jar:/usr/lib/hadoop/lib/jackson-jaxrs-1.9.13.jar:/usr/lib/hadoop/lib/gson-2.2.4.jar:/usr/lib/hadoop/lib/protobuf-java-2.5.0.jar:/usr/lib/hadoop/lib/jsch-0.1.54.jar:/usr/lib/hadoop/lib/commons-io-2.4.jar:/usr/lib/hadoop/lib/commons-configuration-1.6.jar:/usr/lib/hadoop/lib/commons-net-3.1.jar:/usr/lib/hadoop/lib/api-util-1.0.0-M20.jar:/usr/lib/hadoop/lib/mockito-all-1.8.5.jar:/usr/lib/hadoop/lib/xmlenc-0.52.jar:/usr/lib/hadoop/lib/commons-collections-3.2.2.jar:/usr/lib/hadoop/lib/jaxb-impl-2.2.3-1.jar:/usr/lib/hadoop/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/lib/hadoop/lib/apacheds-i18n-2.0.0-M15.jar:/usr/lib/hadoop/lib/slf4j-log4j12-1.7.10.jar:/usr/lib/hadoop/lib/jersey-server-1.9.jar:/usr/lib/hadoop/lib/commons-compress-1.4.1.jar:/usr/lib/hadoop/lib/zookeeper-3.4.12.jar:/usr/lib/hadoop/lib/stax-api-1.0-2.jar:/usr/lib/hadoop/lib/snappy-java-1.0.4.1.jar:/usr/lib/hadoop/lib/curator-client-2.7.1.jar:/usr/lib/hadoop/lib/jackson-mapper-asl-1.9.13.jar:/usr/lib/hadoop/lib/jetty-6.1.26-emr.jar:/usr/lib/hadoop/lib/api-asn1-api-1.0.0-M20.jar:/usr/lib/hadoop/lib/xz-1.0.jar:/usr/lib/hadoop/lib/commons-logging-1.1.3.jar:/usr/lib/hadoop/lib/htrace-core4-4.0.1-incubating.jar:/usr/lib/hadoop/lib/jetty-util-6.1.26-emr.jar:/usr/lib/hadoop/lib/jaxb-api-2.2.2.jar:/usr/lib/hadoop/lib/jsr305-3.0.0.jar:/usr/lib/hadoop/lib/activation-1.1.jar:/usr/lib/hadoop/lib/netty-3.6.2.Final.jar:/usr/lib/hadoop/lib/guava-11.0.2.jar:/usr/lib/hadoop/lib/commons-beanutils-core-1.8.0.jar:/usr/lib/hadoop/lib/log4j-1.2.17.jar:/usr/lib/hadoop/lib/jackson-xc-1.9.13.jar:/usr/lib/hadoop/lib/httpcore-4.4.9.jar:/usr/lib/hadoop/lib/asm-3.2.jar:/usr/lib/hadoop/lib/commons-lang-2.6.jar:/usr/lib/hadoop/lib/commons-digester-1.8.jar:/usr/lib/hadoop/lib/json-smart-1.3.1.jar:/usr/lib/hadoop/lib/commons-codec-1.4.jar:/usr/lib/hadoop/lib/hamcrest-core-1.3.jar:/usr/lib/hadoop/lib/commons-cli-1.2.jar:/usr/lib/hadoop/lib/httpclient-4.5.5.jar:/usr/lib/hadoop/lib/slf4j-api-1.7.10.jar:/usr/lib/hadoop/lib/jsp-api-2.1.jar:/usr/lib/hadoop/lib/jetty-sslengine-6.1.26-emr.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-2.8.4-amzn-1-tests.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-nfs-2.8.4-amzn-1.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-native-client.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-client-2.8.4-amzn-1.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-client.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-native-client-2.8.4-amzn-1.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-nfs.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-2.8.4-amzn-1.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-native-client-2.8.4-amzn-1-tests.jar:/usr/lib/hadoop-hdfs/hadoop-hdfs-client-2.8.4-amzn-1-tests.jar:/usr/lib/hadoop-hdfs/lib/jersey-core-1.9.jar:/usr/lib/hadoop-hdfs/lib/jackson-core-asl-1.9.13.jar:/usr/lib/hadoop-hdfs/lib/servlet-api-2.5.jar:/usr/lib/hadoop-hdfs/lib/protobuf-java-2.5.0.jar:/usr/lib/hadoop-hdfs/lib/commons-io-2.4.jar:/usr/lib/hadoop-hdfs/lib/xmlenc-0.52.jar:/usr/lib/hadoop-hdfs/lib/xercesImpl-2.9.1.jar:/usr/lib/hadoop-hdfs/lib/jersey-server-1.9.jar:/usr/lib/hadoop-hdfs/lib/commons-daemon-1.0.13.jar:/usr/lib/hadoop-hdfs/lib/jackson-mapper-asl-1.9.13.jar:/usr/lib/hadoop-hdfs/lib/jetty-6.1.26-emr.jar:/usr/lib/hadoop-hdfs/lib/commons-logging-1.1.3.jar:/usr/lib/hadoop-hdfs/lib/htrace-core4-4.0.1-incubating.jar:/usr/lib/hadoop-hdfs/lib/jetty-util-6.1.26-emr.jar:/usr/lib/hadoop-hdfs/lib/jsr305-3.0.0.jar:/usr/lib/hadoop-hdfs/lib/netty-all-4.0.23.Final.jar:/usr/lib/hadoop-hdfs/lib/leveldbjni-all-1.8.jar:/usr/lib/hadoop-hdfs/lib/okio-1.4.0.jar:/usr/lib/hadoop-hdfs/lib/netty-3.6.2.Final.jar:/usr/lib/hadoop-hdfs/lib/guava-11.0.2.jar:/usr/lib/hadoop-hdfs/lib/xml-apis-1.3.04.jar:/usr/lib/hadoop-hdfs/lib/log4j-1.2.17.jar:/usr/lib/hadoop-hdfs/lib/okhttp-2.4.0.jar:/usr/lib/hadoop-hdfs/lib/asm-3.2.jar:/usr/lib/hadoop-hdfs/lib/commons-lang-2.6.jar:/usr/lib/hadoop-hdfs/lib/commons-codec-1.4.jar:/usr/lib/hadoop-hdfs/lib/commons-cli-1.2.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-shuffle.jar:/usr/lib/hadoop-mapreduce/ion-java-1.0.2.jar:/usr/lib/hadoop-mapreduce/curator-framework-2.7.1.jar:/usr/lib/hadoop-mapreduce/curator-recipes-2.7.1.jar:/usr/lib/hadoop-mapreduce/commons-beanutils-1.7.0.jar:/usr/lib/hadoop-mapreduce/aws-java-sdk-kms-1.11.336.jar:/usr/lib/hadoop-mapreduce/paranamer-2.3.jar:/usr/lib/hadoop-mapreduce/jmespath-java-1.11.336.jar:/usr/lib/hadoop-mapreduce/jettison-1.1.jar:/usr/lib/hadoop-mapreduce/hadoop-extras-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/java-xmlbuilder-0.4.jar:/usr/lib/hadoop-mapreduce/hadoop-archive-logs.jar:/usr/lib/hadoop-mapreduce/hadoop-auth.jar:/usr/lib/hadoop-mapreduce/hadoop-archive-logs-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/jersey-core-1.9.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-core-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/jcip-annotations-1.0-1.jar:/usr/lib/hadoop-mapreduce/jets3t-0.9.0.jar:/usr/lib/hadoop-mapreduce/jackson-core-asl-1.9.13.jar:/usr/lib/hadoop-mapreduce/audience-annotations-0.5.0.jar:/usr/lib/hadoop-mapreduce/jersey-json-1.9.jar:/usr/lib/hadoop-mapreduce/commons-math3-3.1.1.jar:/usr/lib/hadoop-mapreduce/nimbus-jose-jwt-4.41.1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-jobclient-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/jackson-core-2.6.7.jar:/usr/lib/hadoop-mapreduce/avro-1.7.4.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-hs.jar:/usr/lib/hadoop-mapreduce/hadoop-distcp-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/servlet-api-2.5.jar:/usr/lib/hadoop-mapreduce/jackson-jaxrs-1.9.13.jar:/usr/lib/hadoop-mapreduce/gson-2.2.4.jar:/usr/lib/hadoop-mapreduce/azure-data-lake-store-sdk-2.2.3.jar:/usr/lib/hadoop-mapreduce/protobuf-java-2.5.0.jar:/usr/lib/hadoop-mapreduce/jsch-0.1.54.jar:/usr/lib/hadoop-mapreduce/commons-io-2.4.jar:/usr/lib/hadoop-mapreduce/commons-configuration-1.6.jar:/usr/lib/hadoop-mapreduce/hadoop-streaming.jar:/usr/lib/hadoop-mapreduce/commons-net-3.1.jar:/usr/lib/hadoop-mapreduce/api-util-1.0.0-M20.jar:/usr/lib/hadoop-mapreduce/commons-lang3-3.3.2.jar:/usr/lib/hadoop-mapreduce/xmlenc-0.52.jar:/usr/lib/hadoop-mapreduce/hadoop-distcp.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-jobclient.jar:/usr/lib/hadoop-mapreduce/commons-collections-3.2.2.jar:/usr/lib/hadoop-mapreduce/jaxb-impl-2.2.3-1.jar:/usr/lib/hadoop-mapreduce/hadoop-archives.jar:/usr/lib/hadoop-mapreduce/commons-httpclient-3.1.jar:/usr/lib/hadoop-mapreduce/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-core.jar:/usr/lib/hadoop-mapreduce/hadoop-ant.jar:/usr/lib/hadoop-mapreduce/apacheds-i18n-2.0.0-M15.jar:/usr/lib/hadoop-mapreduce/jackson-databind-2.6.7.1.jar:/usr/lib/hadoop-mapreduce/hadoop-azure-datalake-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-app-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-aws.jar:/usr/lib/hadoop-mapreduce/jersey-server-1.9.jar:/usr/lib/hadoop-mapreduce/jackson-annotations-2.6.7.jar:/usr/lib/hadoop-mapreduce/commons-compress-1.4.1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-common-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/zookeeper-3.4.12.jar:/usr/lib/hadoop-mapreduce/stax-api-1.0-2.jar:/usr/lib/hadoop-mapreduce/snappy-java-1.0.4.1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-hs-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-hs-plugins.jar:/usr/lib/hadoop-mapreduce/curator-client-2.7.1.jar:/usr/lib/hadoop-mapreduce/hadoop-datajoin-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-app.jar:/usr/lib/hadoop-mapreduce/jackson-mapper-asl-1.9.13.jar:/usr/lib/hadoop-mapreduce/jetty-6.1.26-emr.jar:/usr/lib/hadoop-mapreduce/hadoop-ant-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/api-asn1-api-1.0.0-M20.jar:/usr/lib/hadoop-mapreduce/xz-1.0.jar:/usr/lib/hadoop-mapreduce/aws-java-sdk-s3-1.11.336.jar:/usr/lib/hadoop-mapreduce/joda-time-2.9.4.jar:/usr/lib/hadoop-mapreduce/commons-logging-1.1.3.jar:/usr/lib/hadoop-mapreduce/htrace-core4-4.0.1-incubating.jar:/usr/lib/hadoop-mapreduce/jetty-util-6.1.26-emr.jar:/usr/lib/hadoop-mapreduce/hadoop-sls-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-rumen.jar:/usr/lib/hadoop-mapreduce/jaxb-api-2.2.2.jar:/usr/lib/hadoop-mapreduce/jsr305-3.0.0.jar:/usr/lib/hadoop-mapreduce/hadoop-openstack-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-azure-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/activation-1.1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-hs-plugins-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-openstack.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-examples.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-shuffle-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-azure.jar:/usr/lib/hadoop-mapreduce/hadoop-extras.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-jobclient-2.8.4-amzn-1-tests.jar:/usr/lib/hadoop-mapreduce/hadoop-azure-datalake.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-examples-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-mapreduce-client-common.jar:/usr/lib/hadoop-mapreduce/okio-1.4.0.jar:/usr/lib/hadoop-mapreduce/hadoop-gridmix.jar:/usr/lib/hadoop-mapreduce/netty-3.6.2.Final.jar:/usr/lib/hadoop-mapreduce/guava-11.0.2.jar:/usr/lib/hadoop-mapreduce/hadoop-archives-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/commons-beanutils-core-1.8.0.jar:/usr/lib/hadoop-mapreduce/metrics-core-3.0.1.jar:/usr/lib/hadoop-mapreduce/hadoop-datajoin.jar:/usr/lib/hadoop-mapreduce/azure-storage-2.2.0.jar:/usr/lib/hadoop-mapreduce/log4j-1.2.17.jar:/usr/lib/hadoop-mapreduce/jackson-dataformat-cbor-2.6.7.jar:/usr/lib/hadoop-mapreduce/hadoop-gridmix-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/hadoop-rumen-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/jackson-xc-1.9.13.jar:/usr/lib/hadoop-mapreduce/okhttp-2.4.0.jar:/usr/lib/hadoop-mapreduce/httpcore-4.4.9.jar:/usr/lib/hadoop-mapreduce/asm-3.2.jar:/usr/lib/hadoop-mapreduce/hadoop-sls.jar:/usr/lib/hadoop-mapreduce/aws-java-sdk-core-1.11.336.jar:/usr/lib/hadoop-mapreduce/commons-lang-2.6.jar:/usr/lib/hadoop-mapreduce/commons-digester-1.8.jar:/usr/lib/hadoop-mapreduce/json-smart-1.3.1.jar:/usr/lib/hadoop-mapreduce/commons-codec-1.4.jar:/usr/lib/hadoop-mapreduce/hadoop-auth-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/commons-cli-1.2.jar:/usr/lib/hadoop-mapreduce/httpclient-4.5.5.jar:/usr/lib/hadoop-mapreduce/hadoop-streaming-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/jsp-api-2.1.jar:/usr/lib/hadoop-mapreduce/jetty-sslengine-6.1.26-emr.jar:/usr/lib/hadoop-mapreduce/hadoop-aws-2.8.4-amzn-1.jar:/usr/lib/hadoop-mapreduce/lib/paranamer-2.3.jar:/usr/lib/hadoop-mapreduce/lib/jersey-core-1.9.jar:/usr/lib/hadoop-mapreduce/lib/jackson-core-asl-1.9.13.jar:/usr/lib/hadoop-mapreduce/lib/junit-4.11.jar:/usr/lib/hadoop-mapreduce/lib/avro-1.7.4.jar:/usr/lib/hadoop-mapreduce/lib/protobuf-java-2.5.0.jar:/usr/lib/hadoop-mapreduce/lib/commons-io-2.4.jar:/usr/lib/hadoop-mapreduce/lib/javax.inject-1.jar:/usr/lib/hadoop-mapreduce/lib/jersey-server-1.9.jar:/usr/lib/hadoop-mapreduce/lib/commons-compress-1.4.1.jar:/usr/lib/hadoop-mapreduce/lib/snappy-java-1.0.4.1.jar:/usr/lib/hadoop-mapreduce/lib/jackson-mapper-asl-1.9.13.jar:/usr/lib/hadoop-mapreduce/lib/xz-1.0.jar:/usr/lib/hadoop-mapreduce/lib/aopalliance-1.0.jar:/usr/lib/hadoop-mapreduce/lib/jersey-guice-1.9.jar:/usr/lib/hadoop-mapreduce/lib/leveldbjni-all-1.8.jar:/usr/lib/hadoop-mapreduce/lib/netty-3.6.2.Final.jar:/usr/lib/hadoop-mapreduce/lib/log4j-1.2.17.jar:/usr/lib/hadoop-mapreduce/lib/asm-3.2.jar:/usr/lib/hadoop-mapreduce/lib/guice-3.0.jar:/usr/lib/hadoop-mapreduce/lib/hamcrest-core-1.3.jar:/usr/lib/hadoop-mapreduce/lib/guice-servlet-3.0.jar:/usr/lib/hadoop-yarn/hadoop-yarn-common.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-timeline-pluginstorage-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-sharedcachemanager.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-nodemanager-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-timeline-pluginstorage.jar:/usr/lib/hadoop-yarn/hadoop-yarn-api.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-web-proxy-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice.jar:/usr/lib/hadoop-yarn/hadoop-yarn-registry-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-client.jar:/usr/lib/hadoop-yarn/hadoop-yarn-client-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-tests-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-common-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-sharedcachemanager-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-registry.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-common.jar:/usr/lib/hadoop-yarn/hadoop-yarn-applications-distributedshell.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-web-proxy.jar:/usr/lib/hadoop-yarn/hadoop-yarn-applications-unmanaged-am-launcher.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-applicationhistoryservice-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-resourcemanager.jar:/usr/lib/hadoop-yarn/hadoop-yarn-common-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-nodemanager.jar:/usr/lib/hadoop-yarn/hadoop-yarn-server-tests.jar:/usr/lib/hadoop-yarn/hadoop-yarn-api-2.8.4-amzn-1.jar:/usr/lib/hadoop-yarn/lib/curator-test-2.7.1.jar:/usr/lib/hadoop-yarn/lib/java-util-1.9.0.jar:/usr/lib/hadoop-yarn/lib/zookeeper-3.4.12-tests.jar:/usr/lib/hadoop-yarn/lib/jettison-1.1.jar:/usr/lib/hadoop-yarn/lib/jersey-core-1.9.jar:/usr/lib/hadoop-yarn/lib/jackson-core-asl-1.9.13.jar:/usr/lib/hadoop-yarn/lib/audience-annotations-0.5.0.jar:/usr/lib/hadoop-yarn/lib/jersey-json-1.9.jar:/usr/lib/hadoop-yarn/lib/servlet-api-2.5.jar:/usr/lib/hadoop-yarn/lib/jackson-jaxrs-1.9.13.jar:/usr/lib/hadoop-yarn/lib/protobuf-java-2.5.0.jar:/usr/lib/hadoop-yarn/lib/commons-io-2.4.jar:/usr/lib/hadoop-yarn/lib/javax.inject-1.jar:/usr/lib/hadoop-yarn/lib/commons-collections-3.2.2.jar:/usr/lib/hadoop-yarn/lib/jaxb-impl-2.2.3-1.jar:/usr/lib/hadoop-yarn/lib/jersey-server-1.9.jar:/usr/lib/hadoop-yarn/lib/commons-compress-1.4.1.jar:/usr/lib/hadoop-yarn/lib/zookeeper-3.4.12.jar:/usr/lib/hadoop-yarn/lib/stax-api-1.0-2.jar:/usr/lib/hadoop-yarn/lib/commons-math-2.2.jar:/usr/lib/hadoop-yarn/lib/curator-client-2.7.1.jar:/usr/lib/hadoop-yarn/lib/jackson-mapper-asl-1.9.13.jar:/usr/lib/hadoop-yarn/lib/jetty-6.1.26-emr.jar:/usr/lib/hadoop-yarn/lib/xz-1.0.jar:/usr/lib/hadoop-yarn/lib/commons-logging-1.1.3.jar:/usr/lib/hadoop-yarn/lib/aopalliance-1.0.jar:/usr/lib/hadoop-yarn/lib/jetty-util-6.1.26-emr.jar:/usr/lib/hadoop-yarn/lib/jaxb-api-2.2.2.jar:/usr/lib/hadoop-yarn/lib/jsr305-3.0.0.jar:/usr/lib/hadoop-yarn/lib/jersey-guice-1.9.jar:/usr/lib/hadoop-yarn/lib/activation-1.1.jar:/usr/lib/hadoop-yarn/lib/leveldbjni-all-1.8.jar:/usr/lib/hadoop-yarn/lib/netty-3.6.2.Final.jar:/usr/lib/hadoop-yarn/lib/guava-11.0.2.jar:/usr/lib/hadoop-yarn/lib/json-io-2.5.1.jar:/usr/lib/hadoop-yarn/lib/jersey-client-1.9.jar:/usr/lib/hadoop-yarn/lib/fst-2.50.jar:/usr/lib/hadoop-yarn/lib/log4j-1.2.17.jar:/usr/lib/hadoop-yarn/lib/jackson-xc-1.9.13.jar:/usr/lib/hadoop-yarn/lib/asm-3.2.jar:/usr/lib/hadoop-yarn/lib/javassist-3.18.1-GA.jar:/usr/lib/hadoop-yarn/lib/commons-lang-2.6.jar:/usr/lib/hadoop-yarn/lib/commons-codec-1.4.jar:/usr/lib/hadoop-yarn/lib/guice-3.0.jar:/usr/lib/hadoop-yarn/lib/commons-cli-1.2.jar:/usr/lib/hadoop-yarn/lib/guice-servlet-3.0.jar:/usr/lib/hadoop-lzo/lib/hadoop-lzo.jar:/usr/lib/hadoop-lzo/lib/hadoop-lzo-0.4.19.jar:/usr/share/aws/emr/emrfs/conf:/usr/share/aws/emr/emrfs/lib/jcl-over-slf4j-1.7.21.jar:/usr/share/aws/emr/emrfs/lib/ion-java-1.0.2.jar:/usr/share/aws/emr/emrfs/lib/jmespath-java-1.11.336.jar:/usr/share/aws/emr/emrfs/lib/javax.inject-1.jar:/usr/share/aws/emr/emrfs/lib/bcpkix-jdk15on-1.51.jar:/usr/share/aws/emr/emrfs/lib/slf4j-api-1.7.21.jar:/usr/share/aws/emr/emrfs/lib/aopalliance-1.0.jar:/usr/share/aws/emr/emrfs/lib/bcprov-jdk15on-1.51.jar:/usr/share/aws/emr/emrfs/lib/emrfs-hadoop-assembly-2.26.0.jar:/usr/share/aws/emr/emrfs/auxlib/*:/usr/share/aws/emr/lib/*:/usr/share/aws/emr/ddb/lib/emr-ddb-hadoop.jar:/usr/share/aws/emr/goodies/lib/emr-hadoop-goodies.jar:/usr/share/aws/emr/kinesis/lib/emr-kinesis-hadoop.jar:/usr/share/aws/emr/cloudwatch-sink/lib/cloudwatch-sink-1.1.0.jar:/usr/share/aws/emr/cloudwatch-sink/lib/cloudwatch-sink.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-guardduty-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elasticloadbalancingv2-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-opsworks-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elasticache-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-translate-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-acmpca-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-costexplorer-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-applicationautoscaling-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-datapipeline-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-dynamodb-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-marketplaceentitlement-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-kms-1.11.336.jar:/usr/share/aws/aws-java-sdk/jmespath-java-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudhsmv2-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-config-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mediaconvert-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-machinelearning-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cognitoidentity-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-models-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mediapackage-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-batch-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-alexaforbusiness-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-sns-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codestar-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloud9-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-migrationhub-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-dms-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-efs-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudformation-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-appstream-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-secretsmanager-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-devicefarm-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudsearch-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iotanalytics-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-opensdk-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudwatch-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-appsync-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-autoscalingplans-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-ecr-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codegen-maven-plugin-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codedeploy-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elasticbeanstalk-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-xray-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-glue-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-workdocs-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-workspaces-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mechanicalturkrequester-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-logs-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-importexport-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-glacier-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-directory-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-simpleworkflow-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudwatchmetrics-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-polly-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-lexmodelbuilding-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-waf-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-acm-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cognitosync-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-kinesis-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-support-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-transcribe-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codepipeline-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-health-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-organizations-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iot-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-rekognition-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iam-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-emr-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-test-utils-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-lambda-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elastictranscoder-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-marketplacemeteringservice-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-marketplacecommerceanalytics-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-code-generator-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-s3-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mq-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudfront-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mediastore-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-sqs-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-athena-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-kinesisvideo-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-sagemakerruntime-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-medialive-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-ssm-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-redshift-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-serverlessapplicationrepository-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-ec2-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-shield-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-sagemaker-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudtrail-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-autoscaling-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-directconnect-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iot1clickdevices-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-snowball-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-pinpoint-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-resourcegroupstaggingapi-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-simpledb-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-discovery-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-stepfunctions-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-route53-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-connect-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elasticsearch-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-rds-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-sts-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mediastoredata-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-greengrass-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-costandusagereport-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-api-gateway-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-servermigration-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-elasticloadbalancing-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-events-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-core-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-clouddirectory-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-gamelift-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-lex-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iot1clickprojects-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-workmail-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-storagegateway-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-pricing-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-iotjobsdataplane-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codebuild-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-fms-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-dax-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-comprehend-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-codecommit-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-opsworkscm-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-ses-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-ecs-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-inspector-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cognitoidp-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-cloudhsm-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-resourcegroups-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-servicecatalog-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-servicediscovery-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-budgets-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-lightsail-1.11.336.jar:/usr/share/aws/aws-java-sdk/aws-java-sdk-mobile-1.11.336.jar 2018-09-17 15:22:14,390 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - -------------------------------------------------------------------------------- 2018-09-17 15:22:14,390 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Registered UNIX signal handlers for [TERM, HUP, INT] 2018-09-17 15:22:14,393 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - YARN daemon is running as: hadoop Yarn client user obtainer: hadoop 2018-09-17 15:22:14,395 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: env.yarn.conf.dir, /etc/hadoop/conf 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: high-availability.cluster-id, application_1537197527300_0001 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: jobmanager.heap.mb, 8096 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.containers.vcores, 8 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: yarn.maximum-failed-containers, -1 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: internal.cluster.execution-mode, NORMAL 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.memory.fraction, 0.8 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: env.hadoop.conf.dir, /etc/hadoop/conf 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.numberOfTaskSlots, 8 2018-09-17 15:22:14,396 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: akka.ask.timeout, 30 s 2018-09-17 15:22:14,397 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: taskmanager.heap.mb, 51200 2018-09-17 15:22:14,397 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: akka.client.timeout, 300 s 2018-09-17 15:22:14,397 INFO org.apache.flink.configuration.GlobalConfiguration - Loading configuration property: state.checkpoints.dir, s3a://my-test/test/flink/external_join_state 2018-09-17 15:22:14,406 WARN org.apache.flink.configuration.Configuration - Config uses deprecated configuration key 'web.port' instead of proper key 'rest.port' 2018-09-17 15:22:14,409 INFO org.apache.flink.runtime.clusterframework.BootstrapTools - Setting directories for temporary files to: /mnt/yarn/usercache/hadoop/appcache/application_1537197527300_0001 2018-09-17 15:22:14,422 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Starting YarnSessionClusterEntrypoint. 2018-09-17 15:22:14,422 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Install default filesystem. 2018-09-17 15:22:14,491 INFO org.apache.flink.runtime.security.modules.HadoopModule - Hadoop user set to hadoop (auth:SIMPLE) 2018-09-17 15:22:14,505 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Initializing cluster services. 2018-09-17 15:22:14,509 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Trying to start actor system at ip-172-31-37-232.ec2.internal:37959 2018-09-17 15:22:14,957 INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started 2018-09-17 15:22:15,046 INFO akka.remote.Remoting - Starting remoting 2018-09-17 15:22:15,146 INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959] 2018-09-17 15:22:15,152 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint - Actor system started at akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959 2018-09-17 15:22:15,171 INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory /mnt/yarn/usercache/hadoop/appcache/application_1537197527300_0001/blobStore-3453e3e0-2282-4051-92da-67a5aea49f91 2018-09-17 15:22:15,172 INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:43215 - max concurrent requests: 50 - max backlog: 1000 2018-09-17 15:22:15,187 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported. 2018-09-17 15:22:15,190 INFO org.apache.flink.runtime.dispatcher.FileArchivedExecutionGraphStore - Initializing FileArchivedExecutionGraphStore: Storage directory /mnt/yarn/usercache/hadoop/appcache/application_1537197527300_0001/executionGraphStore-c92a946a-c402-480c-bb37-ad5a2dd391d1, expiration time 3600000, maximum cache size 52428800 bytes. 2018-09-17 15:22:15,213 INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory /mnt/yarn/usercache/hadoop/appcache/application_1537197527300_0001/blobStore-acd20b09-106f-4fd2-b2c9-21cafdd156ea 2018-09-17 15:22:15,221 WARN org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Upload directory /tmp/flink-web-21c6f47f-5ea9-4299-9ec1-933f6cdc8be3/flink-web-upload does not exist, or has been deleted externally. Previously uploaded files are no longer available. 2018-09-17 15:22:15,221 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Created directory /tmp/flink-web-21c6f47f-5ea9-4299-9ec1-933f6cdc8be3/flink-web-upload for file uploads. 2018-09-17 15:22:15,224 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest endpoint. 2018-09-17 15:22:15,453 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of main cluster component log file: /var/log/hadoop-yarn/containers/application_1537197527300_0001/container_1537197527300_0001_01_000001/jobmanager.log 2018-09-17 15:22:15,453 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils - Determined location of main cluster component stdout file: /var/log/hadoop-yarn/containers/application_1537197527300_0001/container_1537197527300_0001_01_000001/jobmanager.out 2018-09-17 15:22:15,545 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at ip-172-31-37-232.ec2.internal:39641 2018-09-17 15:22:15,545 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://ip-172-31-37-232.ec2.internal:39641 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000 2018-09-17 15:22:15,545 INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://ip-172-31-37-232.ec2.internal:39641. 2018-09-17 15:22:15,555 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.yarn.YarnResourceManager at akka://flink/user/resourcemanager . 2018-09-17 15:22:15,644 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher . 2018-09-17 15:22:15,658 INFO org.apache.flink.yarn.YarnResourceManager - ResourceManager akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/resourcemanager was granted leadership with fencing token 00000000000000000000000000000000 2018-09-17 15:22:15,659 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Starting the SlotManager. 2018-09-17 15:22:15,679 INFO org.apache.hadoop.yarn.client.RMProxy - Connecting to ResourceManager at ip-172-31-34-15.ec2.internal/172.31.34.15:8030 2018-09-17 15:22:15,905 INFO org.apache.flink.yarn.YarnResourceManager - Recovered 0 containers from previous attempts ([]). 2018-09-17 15:22:15,908 INFO org.apache.hadoop.yarn.client.api.impl.ContainerManagementProtocolProxy - yarn.client.max-cached-nodemanagers-proxies : 0 2018-09-17 15:22:15,922 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Dispatcher akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/dispatcher was granted leadership with fencing token 00000000-0000-0000-0000-000000000000 2018-09-17 15:22:15,922 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Recovering all persisted jobs. 2018-09-17 15:24:08,769 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 8f9ab122fb7452714465eb1e1989e4d7 (Stream to Stream Join). 2018-09-17 15:24:08,782 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_0 . 2018-09-17 15:24:08,789 INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7). 2018-09-17 15:24:08,800 INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart strategy FailureRateRestartStrategy(failuresInterval=300000 msdelayInterval=300000 msmaxFailuresPerInterval=100) for Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7). 2018-09-17 15:24:08,804 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.slotpool.SlotPool at akka://flink/user/e0ff924d-adc5-419c-9aa3-679ceb3ca052 . 2018-09-17 15:24:08,826 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job recovers via failover strategy: full graph restart 2018-09-17 15:24:08,837 INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7). 2018-09-17 15:24:08,837 INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 0 ms. 2018-09-17 15:24:08,870 INFO org.apache.flink.runtime.jobmaster.JobMaster - Using application-defined state backend: RocksDBStateBackend{checkpointStreamBackend=File State Backend (checkpoints: 's3://my-test/analytics_streaming_state', savepoints: 'null', asynchronous: UNDEFINED, fileStateThreshold: -1), localRocksDbDirectories=null, enableIncrementalCheckpointing=TRUE} 2018-09-17 15:24:08,870 INFO org.apache.flink.runtime.jobmaster.JobMaster - Configuring application-defined state backend with job/cluster config 2018-09-17 15:24:11,398 INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManager runner for job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) was granted leadership with session id 00000000-0000-0000-0000-000000000000 at akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/jobmanager_0. 2018-09-17 15:24:11,401 INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) 2018-09-17 15:24:11,403 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) switched from state CREATED to RUNNING. 2018-09-17 15:24:11,407 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (99ce4cfd3c0c8b43f83004dc0db41f7b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,411 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (d3775a65bbe832cd4959db13cb3b5743) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,411 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (56982bebad5da8c4f2989b6c49ad62c9) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,411 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (1/16) (e16b36756729da529ba33ff0fd871df6) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,411 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (2/16) (ba5cb8abf132b51233fe2c125a9b1c49) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (3/16) (87e8af80bdb34197d891752570318753) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (4/16) (d592daa640e08de3bd8fbae17cd54d39) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (5/16) (692ad1144f5167f0802f8fe1a4289f35) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (6/16) (ffce25842ab2e82b71f97229225ac015) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (7/16) (c65a9af6cb93cbf325ac5399721922bb) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (8/16) (e542692f4650a01fc3fab27adb15d89b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (9/16) (c3f49133206abb7574a241fac87d5040) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,412 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (10/16) (3c4b41cf0ad4093476a022a817f563c7) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (11/16) (d2b24c10bcf9a38b5883aaf84affb762) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (12/16) (2bf7a7cd9b973e1f2021bfc225d967d6) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (13/16) (65f8081b6d9d6089172abcc1d03208fd) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (14/16) (ac997fd3a0b470d66064ed17fd53f445) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (15/16) (60c6361786268e056f8d93c8fa97e730) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (16/16) (6b592ac9803a3a8cfc22843cc43df1d2) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (e22f0b124f47d6d40d964abf6a05b556) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (f9cd15d98d13ebb84db0e5001e1ff279) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (5a501051ec38450ae41f0a954253680d) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (52954a6d00a5dc0fbc720573a86f0178) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (10cfb3622d8991fe3e121a7b04635532) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,413 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (fbfafe2ad41dba842be581e93f9d734b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (85ded6090632764297adefe2f67d03e2) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (519422fdce76dd4e935eacefe9ffb5af) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (56be5e5097ccf9ae90ed3e7d98fbfc7a) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (bdeaf70e5c3291e02f5e9f5a85851fa1) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (8ec8c6830b08c3558a13083be4529896) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (ed2994c505c46cf1fd9248389544c15f) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (8dffad28a951698dbb5aad4f4d60d315) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (41c982ca99b29a7574747cdccbde3465) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (ee1d6509eca8c1ebd8cbfc26cd1f1812) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (1447440a5f6a2da2a79408d72fae6b71) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (1/16) (d3f0bcfb034a74237500ee3d9455407c) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,414 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (2/16) (349778e54003fbab873d582cf654883d) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (3/16) (7b59c470d766dc384d75de2727ec78b3) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (4/16) (50282ff30e2e25eaa1d16a32b1a66ed5) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (5/16) (b6f8f2f01f610ba0c5e885439b59808b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (6/16) (ea1fb9efb6aacad4fb52b7e9abc72de9) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (7/16) (20f1ca859fb0ccb85ae1cb38caba0dae) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (8/16) (751aa99cae95bc90ff58f5f9902990fd) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (9/16) (8f8db004c75b8f5388d04210aa3b3a5b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (10/16) (2a15393cb7f5b87dd4c2b62e874ae3e9) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (11/16) (0e60588370d8083878400fb917b0f0e3) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (12/16) (455c4019a2e5eeabd62118f6e0068658) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (13/16) (03dec6dc3d1920a25eafe7816f6d272c) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,415 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (14/16) (5a6bb8000145d95fb9338ee871204f4b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (15/16) (3f6ed92bfb4e35c0ee7913a16c94ea2f) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (16/16) (9be0d2be1a1d64929609aa3626e3c096) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (1/16) (ad8b7610719398e6661ed03ea9d55e8d) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (2/16) (4f76ec6f3d92b7e0accd6dda9af695d5) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (3/16) (f8e59fa9b92365713ca1003f31f60a5f) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,416 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (4/16) (38ee7856035c56fd54c0ab03d87610b0) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (5/16) (ba1c7247efbf8ddc093020a43492ac63) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (6/16) (cdbc411bbe1461dc1e151b0105b8dea4) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (7/16) (e08a04b23e885bbd5c0363df2ea944b5) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (8/16) (feb10daaf620dfb461916d6508c0066c) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (9/16) (994fb1ef8ec7a7e97cb77aa0c5dc14b3) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,417 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (10/16) (13f1312c3d7c0ef824bb5801377fb807) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,418 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (11/16) (3cafa94cd0732a7443aaa3d9cb046efa) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,418 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (12/16) (b5f01b06c630b5609ca5a6e3ebfc1cb2) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,418 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (13/16) (84ea7e5125e2cab4427cbcbb47198767) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,418 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (14/16) (6c6fe6e4d08a6fde40624c5f993a26e8) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,418 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (15/16) (77a0b8c3a9baef3e4cb350b6cf6b4317) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,419 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (16/16) (1c84ecb045fa02a89c1871073e046268) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,419 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (ce49668d2432c58fea42c159e6aaec1d) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,419 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{f549dc746c4916fbbabdeeace655ce09}] 2018-09-17 15:24:11,419 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (aab864b0c40acde6b181a97c9e310867) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,420 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (8bd71ccacd283e6d511293fd51b9fa22) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,420 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (4e9d509115ada93455be83a85283c42f) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,421 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (ce8ea1bf6fae6d4dfa85b12bd9caa040) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,421 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (cdc6a260439ebbc2b7b4defe2c6c8ef3) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,421 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (3f7f254aa98a77c914a1877cbaad5522) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,421 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (458c92f027dd6636147849558dac7a78) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,422 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (d6c44653bc3a6030275b3628e3241d48) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,422 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (a0fd3658b0867d272cc3e76d4a20af99) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,422 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (fd9b6f428728680594f77d8f85cef185) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,422 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (2f9b2076fccb53a33b98ed611f7ebcc2) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,423 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (161842846ef8427eff483fb1ebce7581) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,423 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (c29c19668ccf95aa1803a737f1dc3476) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,423 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (374a1709ed58170599e990b58b96fe37) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,423 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (fa99e20e4c77f2b0aa49115a3d1b9bca) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (1/16) (fbe708927873981fe2ff01135498a8e7) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (2/16) (93f9ccde3c0a7bd2f0d0dd131badd18b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{c8fdb8e615685412febdb105be80fdcc}] 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (3/16) (f69f15226d7a769c87f2e5ecdaed2989) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{bacb0fbaa1c97d0f180811f5927a4b93}] 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (4/16) (9de77250fded2ebfac860e9ab7269144) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,424 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{b3c0669c223e41ca5be8ca847928db3e}] 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (5/16) (840034a18950d275976e64f818953438) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{db9433a98d239f18ccec1232e5ff3c69}] 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (6/16) (e26a900ff19da26bfb5e0a4501ce5772) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{cae50ad945a2f6b03a94a716b4ee16c3}] 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (7/16) (de42d0da18524c412616bba4ef4b7813) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{4369a9be7ad05d018a069c7d3f5cb144}] 2018-09-17 15:24:11,425 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (8/16) (0d89a0029831150b3823eaa059a9b9d0) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{af58f99b23da40533c44a9d702bb94b3}] 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (9/16) (8da157d2d887d3d3f38f65a45df8a575) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{189c33a7ab0f2521d3ac05ea51ba6558}] 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (10/16) (77716853f28cbc147052907f60b2375d) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{c78593a4a72173b5745d1a3ac19f4ffd}] 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (11/16) (d9e1cbd5a899f8415b862ce5b9363dfc) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,426 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{c37a449c8250930689ad9ab617afa62b}] 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (12/16) (07a08b6b1e52143c4492b2f194e30856) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{f07e73fbdf39cccff1dacda1064685a3}] 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (13/16) (f163536b17f737dfe1e3399e4a256485) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{511eb6d4a44ab6f091390fc0895fa71b}] 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (14/16) (7a1717f2467f317724dcef4a4519ee36) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (15/16) (2eafc95c8d2e50436b1d223a9099ad2c) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,427 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{a12413511262ff7db32daa66261e0093}] 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (16/16) (8f8a18d13cc30ef9193fd917bfcc03bc) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{ee210c631e666b40c753ebbc32f23bf0}] 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (603e0d160161de28eb53ed4342c6e19b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{5ace167335e7a15b52445bd5e6b05403}] 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (25914cb3f77c8e4271b0fb6ea597ed50) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,428 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (5d2e73c821bae604f8eba874e7f68415) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,429 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (f19b25325085df39884a0a2dd88e8ce4) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,429 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (72e64a9b4d6c8071c13c1114055ecb4e) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,429 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (60abd0b940901df1c9be682a7b290b8c) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,429 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (6ee163d12edf35e90530ef18fbb07bd3) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,430 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (d413f07d38a55becac18329b2173c6ec) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,430 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (8bf5ecae8d69e79cd8d3871c2c55c403) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,430 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (f89aacf4f37e5aa4c3c7a99df680cfbe) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,430 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (dfbb49fd9238b1eb37180adc30fe2291) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,431 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (9c25da5c24e51605a70728b2753bb850) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,431 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (b640048a4d3d9eed6ab899bab9509d05) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,431 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (6d922d30cdee1ef1bf95af3b2178b303) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,431 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (10e0c5a5a39528ed2a3fd13f2f3e463b) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,432 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (16ad7eb74c12c5bb6909f902af5900cd) switched from CREATED to SCHEDULED. 2018-09-17 15:24:11,434 INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/resourcemanager(00000000000000000000000000000000) 2018-09-17 15:24:11,438 INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration 2018-09-17 15:24:11,438 INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms) 2018-09-17 15:24:11,439 INFO org.apache.flink.yarn.YarnResourceManager - Registering job manager 00000000000000000000000000000000@akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/jobmanager_0 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:24:11,443 INFO org.apache.flink.yarn.YarnResourceManager - Registered job manager 00000000000000000000000000000000@akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/jobmanager_0 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:24:11,446 INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: 00000000000000000000000000000000. 2018-09-17 15:24:11,447 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{cae50ad945a2f6b03a94a716b4ee16c3}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{29f5c97df94fbe2538d9bce146a3cb1d}. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{f549dc746c4916fbbabdeeace655ce09}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{bacb0fbaa1c97d0f180811f5927a4b93}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{5ace167335e7a15b52445bd5e6b05403}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{4369a9be7ad05d018a069c7d3f5cb144}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{ee210c631e666b40c753ebbc32f23bf0}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,449 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{a12413511262ff7db32daa66261e0093}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{f07e73fbdf39cccff1dacda1064685a3}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{511eb6d4a44ab6f091390fc0895fa71b}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{db9433a98d239f18ccec1232e5ff3c69}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{c37a449c8250930689ad9ab617afa62b}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{c78593a4a72173b5745d1a3ac19f4ffd}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,450 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{af58f99b23da40533c44a9d702bb94b3}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,451 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{189c33a7ab0f2521d3ac05ea51ba6558}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,451 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{b3c0669c223e41ca5be8ca847928db3e}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,451 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Requesting new slot [SlotRequestId{c8fdb8e615685412febdb105be80fdcc}] and profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} from resource manager. 2018-09-17 15:24:11,457 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 1. 2018-09-17 15:24:11,457 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{119fda5a59490bd2444c31b5c9b53d93}. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 2. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{5b3c27ade2225b6b66a3bd905eb46d62}. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 3. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{6a586c690b803f174c90dd6ab0ba4a3c}. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 4. 2018-09-17 15:24:11,458 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{a017455e764988aba83f9f600840bb36}. 2018-09-17 15:24:11,459 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 5. 2018-09-17 15:24:11,459 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{214d03473f4c4d6024ddee4d96762b9a}. 2018-09-17 15:24:11,459 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 6. 2018-09-17 15:24:11,459 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{a509190b0782f0c5a4c873b6377c90fc}. 2018-09-17 15:24:11,459 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 7. 2018-09-17 15:24:11,460 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{bb51aa436daa6af7d98933e7134a3e8b}. 2018-09-17 15:24:11,460 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 8. 2018-09-17 15:24:11,460 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{f42afdfa223a3e0e69e1485a197419a8}. 2018-09-17 15:24:11,460 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 9. 2018-09-17 15:24:11,460 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{105cd9b45ae1ceda99c95c5f188e03bc}. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 10. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{fc0408b0ecb614ce48eacff7cf478d46}. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 11. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{4f1e9371a775d53cc7cda503c9384632}. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 12. 2018-09-17 15:24:11,461 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{c6256b7c0ff9ddc289159a9eb4b03f71}. 2018-09-17 15:24:11,462 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 13. 2018-09-17 15:24:11,462 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{ecae8f5b5f49f204c4eb1ac7871691c5}. 2018-09-17 15:24:11,462 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 14. 2018-09-17 15:24:11,462 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{aa3eeae8be26609a5752de44b3a8fddc}. 2018-09-17 15:24:11,463 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 15. 2018-09-17 15:24:11,463 INFO org.apache.flink.yarn.YarnResourceManager - Request slot with profile ResourceProfile{cpuCores=-1.0, heapMemoryInMB=-1, directMemoryInMB=0, nativeMemoryInMB=0, networkMemoryInMB=0} for job 8f9ab122fb7452714465eb1e1989e4d7 with allocation id AllocationID{a62377cf4d61734c31016ac2ba0cf9a0}. 2018-09-17 15:24:11,464 INFO org.apache.flink.yarn.YarnResourceManager - Requesting new TaskExecutor container with resources . Number pending requests 16. 2018-09-17 15:24:16,542 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : ip-172-31-41-250.ec2.internal:8041 2018-09-17 15:24:16,543 INFO org.apache.hadoop.yarn.client.api.impl.AMRMClientImpl - Received new token for : ip-172-31-37-51.ec2.internal:8041 2018-09-17 15:24:16,547 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000002 - Remaining pending container requests: 16 2018-09-17 15:24:17,022 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:24:17,023 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:24:17,284 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000003 - Remaining pending container requests: 15 2018-09-17 15:24:17,709 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:24:17,710 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:24:21,372 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000002 under 6e9d624c59632e7cbb65cf3fc853becd at the SlotManager. 2018-09-17 15:24:21,404 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Checkpoint triggering task Source: s3://my-test/flume/avro/enrollment_log/ (1/1) of job 8f9ab122fb7452714465eb1e1989e4d7 is not in state RUNNING but SCHEDULED instead. Aborting checkpoint. 2018-09-17 15:24:22,081 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000003 under fee9575f3feeef3b1ac634fd100283ae at the SlotManager. 2018-09-17 15:24:22,145 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (9c25da5c24e51605a70728b2753bb850) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,146 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,158 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (12/16) (b5f01b06c630b5609ca5a6e3ebfc1cb2) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,158 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,161 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (12/16) (07a08b6b1e52143c4492b2f194e30856) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,161 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,162 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (2f9b2076fccb53a33b98ed611f7ebcc2) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,162 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,164 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (25914cb3f77c8e4271b0fb6ea597ed50) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,164 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (2/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,165 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (6d922d30cdee1ef1bf95af3b2178b303) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,165 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,166 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (99ce4cfd3c0c8b43f83004dc0db41f7b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,166 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,167 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (2/16) (93f9ccde3c0a7bd2f0d0dd131badd18b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,167 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (2/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,168 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (14/16) (7a1717f2467f317724dcef4a4519ee36) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,169 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,170 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (c29c19668ccf95aa1803a737f1dc3476) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,170 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,171 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (7/16) (e08a04b23e885bbd5c0363df2ea944b5) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,171 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (7/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,172 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (72e64a9b4d6c8071c13c1114055ecb4e) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,172 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (5/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,173 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (5/16) (840034a18950d275976e64f818953438) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,173 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (5/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,174 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (aab864b0c40acde6b181a97c9e310867) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,174 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (2/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,175 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (ce8ea1bf6fae6d4dfa85b12bd9caa040) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,175 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (5/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,175 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (10/16) (13f1312c3d7c0ef824bb5801377fb807) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,175 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,176 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (f89aacf4f37e5aa4c3c7a99df680cfbe) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,176 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,178 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (a0fd3658b0867d272cc3e76d4a20af99) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,178 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,178 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (13/16) (84ea7e5125e2cab4427cbcbb47198767) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,178 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,179 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (10/16) (77716853f28cbc147052907f60b2375d) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,179 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,180 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (b640048a4d3d9eed6ab899bab9509d05) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,180 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,181 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (13/16) (f163536b17f737dfe1e3399e4a256485) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,181 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,182 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (161842846ef8427eff483fb1ebce7581) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,182 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,183 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (6/16) (cdbc411bbe1461dc1e151b0105b8dea4) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,183 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (6/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,184 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (6ee163d12edf35e90530ef18fbb07bd3) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,184 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (7/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,185 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (3f7f254aa98a77c914a1877cbaad5522) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,185 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (7/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,186 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (7/16) (de42d0da18524c412616bba4ef4b7813) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,186 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (7/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,186 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (9/16) (994fb1ef8ec7a7e97cb77aa0c5dc14b3) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,187 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (9/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,187 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (603e0d160161de28eb53ed4342c6e19b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,188 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (1/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,188 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (1/16) (fbe708927873981fe2ff01135498a8e7) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,189 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (1/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,189 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (8/16) (feb10daaf620dfb461916d6508c0066c) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,190 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (8/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,190 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (ce49668d2432c58fea42c159e6aaec1d) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,191 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (1/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,191 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (d3775a65bbe832cd4959db13cb3b5743) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,191 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,192 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (1/16) (ad8b7610719398e6661ed03ea9d55e8d) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,192 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (1/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,193 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (1447440a5f6a2da2a79408d72fae6b71) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,193 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,194 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (ee1d6509eca8c1ebd8cbfc26cd1f1812) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,195 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,195 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (41c982ca99b29a7574747cdccbde3465) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,195 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,196 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (8dffad28a951698dbb5aad4f4d60d315) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,196 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,196 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (ed2994c505c46cf1fd9248389544c15f) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,196 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,197 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (8ec8c6830b08c3558a13083be4529896) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,197 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,197 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (bdeaf70e5c3291e02f5e9f5a85851fa1) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,198 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,198 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (56be5e5097ccf9ae90ed3e7d98fbfc7a) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,198 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,199 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (56982bebad5da8c4f2989b6c49ad62c9) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,199 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,200 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (16/16) (6b592ac9803a3a8cfc22843cc43df1d2) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,200 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (16/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,200 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (15/16) (60c6361786268e056f8d93c8fa97e730) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,201 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (15/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,201 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (14/16) (ac997fd3a0b470d66064ed17fd53f445) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,201 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,202 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (13/16) (65f8081b6d9d6089172abcc1d03208fd) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,202 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,202 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (12/16) (2bf7a7cd9b973e1f2021bfc225d967d6) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,202 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,203 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (11/16) (d2b24c10bcf9a38b5883aaf84affb762) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,203 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (11/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,203 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (10/16) (3c4b41cf0ad4093476a022a817f563c7) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (9/16) (c3f49133206abb7574a241fac87d5040) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (9/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (16/16) (9be0d2be1a1d64929609aa3626e3c096) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,204 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (16/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,205 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (15/16) (3f6ed92bfb4e35c0ee7913a16c94ea2f) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,205 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (15/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,206 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (14/16) (5a6bb8000145d95fb9338ee871204f4b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,206 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (14/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,206 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (13/16) (03dec6dc3d1920a25eafe7816f6d272c) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,206 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (13/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,207 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (12/16) (455c4019a2e5eeabd62118f6e0068658) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,207 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (12/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,207 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (11/16) (0e60588370d8083878400fb917b0f0e3) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,207 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (11/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (10/16) (2a15393cb7f5b87dd4c2b62e874ae3e9) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (10/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (9/16) (8f8db004c75b8f5388d04210aa3b3a5b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,208 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (9/16) (attempt #0) to ip-172-31-37-51 2018-09-17 15:24:22,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (16/16) (8f8a18d13cc30ef9193fd917bfcc03bc) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,209 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (16/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,210 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (16ad7eb74c12c5bb6909f902af5900cd) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,210 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (16/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,210 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (11/16) (3cafa94cd0732a7443aaa3d9cb046efa) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,210 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (11/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,211 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (fa99e20e4c77f2b0aa49115a3d1b9bca) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,211 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (16/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,211 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (1/16) (e16b36756729da529ba33ff0fd871df6) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,211 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (1/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,212 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (e22f0b124f47d6d40d964abf6a05b556) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,212 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,212 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (5a501051ec38450ae41f0a954253680d) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,212 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,213 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (11/16) (d9e1cbd5a899f8415b862ce5b9363dfc) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,213 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (11/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,213 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (dfbb49fd9238b1eb37180adc30fe2291) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,213 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (11/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,214 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (fd9b6f428728680594f77d8f85cef185) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,214 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (11/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,214 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (5/16) (ba1c7247efbf8ddc093020a43492ac63) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,215 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (5/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,215 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (3/16) (87e8af80bdb34197d891752570318753) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,215 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,216 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (10cfb3622d8991fe3e121a7b04635532) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,216 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,216 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (8/16) (0d89a0029831150b3823eaa059a9b9d0) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,216 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,217 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (d413f07d38a55becac18329b2173c6ec) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,217 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,217 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (4/16) (38ee7856035c56fd54c0ab03d87610b0) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,218 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,218 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (458c92f027dd6636147849558dac7a78) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,218 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,219 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (5/16) (692ad1144f5167f0802f8fe1a4289f35) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,219 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (5/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,219 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (52954a6d00a5dc0fbc720573a86f0178) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,219 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,220 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (8bf5ecae8d69e79cd8d3871c2c55c403) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,220 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (9/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,220 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (9/16) (8da157d2d887d3d3f38f65a45df8a575) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,220 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (9/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,221 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (d6c44653bc3a6030275b3628e3241d48) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,221 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (9/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,221 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (16/16) (1c84ecb045fa02a89c1871073e046268) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,221 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (16/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,222 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (4/16) (d592daa640e08de3bd8fbae17cd54d39) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,222 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,222 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (85ded6090632764297adefe2f67d03e2) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,223 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,223 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (f19b25325085df39884a0a2dd88e8ce4) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,223 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,224 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (4/16) (9de77250fded2ebfac860e9ab7269144) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,224 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,224 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (4e9d509115ada93455be83a85283c42f) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,224 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (15/16) (77a0b8c3a9baef3e4cb350b6cf6b4317) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (15/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (7/16) (c65a9af6cb93cbf325ac5399721922bb) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,225 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (7/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,226 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (10e0c5a5a39528ed2a3fd13f2f3e463b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,226 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (15/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (f9cd15d98d13ebb84db0e5001e1ff279) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (15/16) (2eafc95c8d2e50436b1d223a9099ad2c) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (15/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,227 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (374a1709ed58170599e990b58b96fe37) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,228 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (15/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,228 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (14/16) (6c6fe6e4d08a6fde40624c5f993a26e8) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,228 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (14/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (2/16) (ba5cb8abf132b51233fe2c125a9b1c49) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,229 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (2/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (fbfafe2ad41dba842be581e93f9d734b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (60abd0b940901df1c9be682a7b290b8c) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,230 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (cdc6a260439ebbc2b7b4defe2c6c8ef3) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (6/16) (e26a900ff19da26bfb5e0a4501ce5772) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,231 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,232 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (3/16) (f8e59fa9b92365713ca1003f31f60a5f) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,232 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,233 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (519422fdce76dd4e935eacefe9ffb5af) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,233 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,233 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (6/16) (ffce25842ab2e82b71f97229225ac015) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,233 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,233 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (5d2e73c821bae604f8eba874e7f68415) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,234 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,234 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (3/16) (f69f15226d7a769c87f2e5ecdaed2989) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,234 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Chapter ID -> Map (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,234 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (8bd71ccacd283e6d511293fd51b9fa22) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,235 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Sink: Unnamed (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,235 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (2/16) (4f76ec6f3d92b7e0accd6dda9af695d5) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,235 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Get Min Event Time Of Member ID -> Map (2/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,235 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (8/16) (e542692f4650a01fc3fab27adb15d89b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,236 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Filter (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,236 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (1/16) (d3f0bcfb034a74237500ee3d9455407c) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,236 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (1/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,236 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (3/16) (7b59c470d766dc384d75de2727ec78b3) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,236 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (3/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,237 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (5/16) (b6f8f2f01f610ba0c5e885439b59808b) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,237 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (5/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,237 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (4/16) (50282ff30e2e25eaa1d16a32b1a66ed5) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,237 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (4/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,238 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (7/16) (20f1ca859fb0ccb85ae1cb38caba0dae) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,238 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (7/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,238 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (2/16) (349778e54003fbab873d582cf654883d) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,238 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (2/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,239 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (6/16) (ea1fb9efb6aacad4fb52b7e9abc72de9) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,239 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (6/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:22,239 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (8/16) (751aa99cae95bc90ff58f5f9902990fd) switched from SCHEDULED to DEPLOYING. 2018-09-17 15:24:22,239 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Timestamps/Watermarks -> (Filter, Filter) (8/16) (attempt #0) to ip-172-31-41-250 2018-09-17 15:24:23,536 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (25914cb3f77c8e4271b0fb6ea597ed50) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,536 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (ce8ea1bf6fae6d4dfa85b12bd9caa040) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,540 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (6ee163d12edf35e90530ef18fbb07bd3) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,545 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (a0fd3658b0867d272cc3e76d4a20af99) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,545 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (b640048a4d3d9eed6ab899bab9509d05) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,547 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (ce49668d2432c58fea42c159e6aaec1d) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,548 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (9c25da5c24e51605a70728b2753bb850) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,551 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (72e64a9b4d6c8071c13c1114055ecb4e) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,554 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (603e0d160161de28eb53ed4342c6e19b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,555 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (3f7f254aa98a77c914a1877cbaad5522) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,555 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (c29c19668ccf95aa1803a737f1dc3476) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,556 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (161842846ef8427eff483fb1ebce7581) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,556 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (6d922d30cdee1ef1bf95af3b2178b303) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,557 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (aab864b0c40acde6b181a97c9e310867) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,560 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (f89aacf4f37e5aa4c3c7a99df680cfbe) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,560 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (2f9b2076fccb53a33b98ed611f7ebcc2) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (fd9b6f428728680594f77d8f85cef185) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,613 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (dfbb49fd9238b1eb37180adc30fe2291) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,614 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (f19b25325085df39884a0a2dd88e8ce4) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,615 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (4e9d509115ada93455be83a85283c42f) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,616 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (5d2e73c821bae604f8eba874e7f68415) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,616 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (60abd0b940901df1c9be682a7b290b8c) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,617 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (458c92f027dd6636147849558dac7a78) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,617 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (374a1709ed58170599e990b58b96fe37) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,617 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (d413f07d38a55becac18329b2173c6ec) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,618 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (16ad7eb74c12c5bb6909f902af5900cd) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,618 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (8bd71ccacd283e6d511293fd51b9fa22) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,619 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (fa99e20e4c77f2b0aa49115a3d1b9bca) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,620 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (d6c44653bc3a6030275b3628e3241d48) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,620 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (10e0c5a5a39528ed2a3fd13f2f3e463b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,620 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (cdc6a260439ebbc2b7b4defe2c6c8ef3) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,620 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (8bf5ecae8d69e79cd8d3871c2c55c403) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,848 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (7/16) (de42d0da18524c412616bba4ef4b7813) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,851 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (8ec8c6830b08c3558a13083be4529896) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,860 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (ee1d6509eca8c1ebd8cbfc26cd1f1812) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,861 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (13/16) (84ea7e5125e2cab4427cbcbb47198767) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,862 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (13/16) (f163536b17f737dfe1e3399e4a256485) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,862 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (8dffad28a951698dbb5aad4f4d60d315) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,864 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (16/16) (6b592ac9803a3a8cfc22843cc43df1d2) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,864 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (13/16) (03dec6dc3d1920a25eafe7816f6d272c) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,864 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (1/16) (ad8b7610719398e6661ed03ea9d55e8d) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,866 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (13/16) (65f8081b6d9d6089172abcc1d03208fd) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,866 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (7/16) (e08a04b23e885bbd5c0363df2ea944b5) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,867 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (12/16) (b5f01b06c630b5609ca5a6e3ebfc1cb2) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,868 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (5/16) (840034a18950d275976e64f818953438) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,869 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (1447440a5f6a2da2a79408d72fae6b71) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,870 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (14/16) (5a6bb8000145d95fb9338ee871204f4b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,871 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (9/16) (c3f49133206abb7574a241fac87d5040) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,871 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (ed2994c505c46cf1fd9248389544c15f) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,876 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (10/16) (3c4b41cf0ad4093476a022a817f563c7) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,877 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (14/16) (ac997fd3a0b470d66064ed17fd53f445) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,877 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (11/16) (0e60588370d8083878400fb917b0f0e3) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,878 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (12/16) (455c4019a2e5eeabd62118f6e0068658) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,879 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (15/16) (3f6ed92bfb4e35c0ee7913a16c94ea2f) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,881 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (1/16) (fbe708927873981fe2ff01135498a8e7) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,882 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (8/16) (feb10daaf620dfb461916d6508c0066c) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,882 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (41c982ca99b29a7574747cdccbde3465) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,883 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (12/16) (2bf7a7cd9b973e1f2021bfc225d967d6) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,885 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (10/16) (77716853f28cbc147052907f60b2375d) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,885 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (99ce4cfd3c0c8b43f83004dc0db41f7b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,886 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (15/16) (60c6361786268e056f8d93c8fa97e730) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,886 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (11/16) (d2b24c10bcf9a38b5883aaf84affb762) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,887 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (d3775a65bbe832cd4959db13cb3b5743) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,888 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (6/16) (cdbc411bbe1461dc1e151b0105b8dea4) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,889 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (10/16) (13f1312c3d7c0ef824bb5801377fb807) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,890 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (14/16) (7a1717f2467f317724dcef4a4519ee36) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,893 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (2/16) (93f9ccde3c0a7bd2f0d0dd131badd18b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,893 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (56be5e5097ccf9ae90ed3e7d98fbfc7a) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,893 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (56982bebad5da8c4f2989b6c49ad62c9) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,893 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (bdeaf70e5c3291e02f5e9f5a85851fa1) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,895 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (9/16) (8f8db004c75b8f5388d04210aa3b3a5b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,895 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (10/16) (2a15393cb7f5b87dd4c2b62e874ae3e9) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,898 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (12/16) (07a08b6b1e52143c4492b2f194e30856) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,898 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (9/16) (994fb1ef8ec7a7e97cb77aa0c5dc14b3) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,899 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (16/16) (9be0d2be1a1d64929609aa3626e3c096) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,924 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (85ded6090632764297adefe2f67d03e2) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (1/16) (e16b36756729da529ba33ff0fd871df6) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (6/16) (ffce25842ab2e82b71f97229225ac015) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (4/16) (d592daa640e08de3bd8fbae17cd54d39) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,932 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (11/16) (3cafa94cd0732a7443aaa3d9cb046efa) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,933 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (2/16) (ba5cb8abf132b51233fe2c125a9b1c49) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,935 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (5a501051ec38450ae41f0a954253680d) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,936 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (5/16) (692ad1144f5167f0802f8fe1a4289f35) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,936 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (52954a6d00a5dc0fbc720573a86f0178) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (2/16) (4f76ec6f3d92b7e0accd6dda9af695d5) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,937 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (f9cd15d98d13ebb84db0e5001e1ff279) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,938 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (11/16) (d9e1cbd5a899f8415b862ce5b9363dfc) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,939 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (15/16) (77a0b8c3a9baef3e4cb350b6cf6b4317) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,940 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (fbfafe2ad41dba842be581e93f9d734b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,941 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (8/16) (0d89a0029831150b3823eaa059a9b9d0) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,942 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (5/16) (b6f8f2f01f610ba0c5e885439b59808b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,943 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (6/16) (e26a900ff19da26bfb5e0a4501ce5772) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,944 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (3/16) (f69f15226d7a769c87f2e5ecdaed2989) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,944 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (7/16) (c65a9af6cb93cbf325ac5399721922bb) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,945 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (e22f0b124f47d6d40d964abf6a05b556) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,946 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (519422fdce76dd4e935eacefe9ffb5af) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,948 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (5/16) (ba1c7247efbf8ddc093020a43492ac63) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,948 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (16/16) (8f8a18d13cc30ef9193fd917bfcc03bc) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,949 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (3/16) (7b59c470d766dc384d75de2727ec78b3) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,949 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (4/16) (38ee7856035c56fd54c0ab03d87610b0) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,951 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (4/16) (50282ff30e2e25eaa1d16a32b1a66ed5) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,951 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (10cfb3622d8991fe3e121a7b04635532) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,952 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (16/16) (1c84ecb045fa02a89c1871073e046268) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,953 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (2/16) (349778e54003fbab873d582cf654883d) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,954 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (3/16) (87e8af80bdb34197d891752570318753) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,955 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (3/16) (f8e59fa9b92365713ca1003f31f60a5f) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,956 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (4/16) (9de77250fded2ebfac860e9ab7269144) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,957 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (9/16) (8da157d2d887d3d3f38f65a45df8a575) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,957 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (8/16) (e542692f4650a01fc3fab27adb15d89b) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,957 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (15/16) (2eafc95c8d2e50436b1d223a9099ad2c) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,958 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (8/16) (751aa99cae95bc90ff58f5f9902990fd) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,958 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (7/16) (20f1ca859fb0ccb85ae1cb38caba0dae) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,959 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (14/16) (6c6fe6e4d08a6fde40624c5f993a26e8) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,959 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (6/16) (ea1fb9efb6aacad4fb52b7e9abc72de9) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:23,961 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (1/16) (d3f0bcfb034a74237500ee3d9455407c) switched from DEPLOYING to RUNNING. 2018-09-17 15:24:31,603 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 1 @ 1537197871404 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:26:29,673 INFO com.amazon.ws.emr.hadoop.fs.s3n.MultipartUploadOutputStream - close closed:false s3://my-test/analytics_streaming_state/8f9ab122fb7452714465eb1e1989e4d7/chk-1/_metadata 2018-09-17 15:26:29,743 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 1 for job 8f9ab122fb7452714465eb1e1989e4d7 (43843757 bytes in 118338 ms). 2018-09-17 15:26:39,887 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 2 @ 1537197999743 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:39:21,445 INFO com.amazon.ws.emr.hadoop.fs.s3n.MultipartUploadOutputStream - close closed:false s3://my-test/analytics_streaming_state/8f9ab122fb7452714465eb1e1989e4d7/chk-2/_metadata 2018-09-17 15:39:25,942 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 2 for job 8f9ab122fb7452714465eb1e1989e4d7 (569625682 bytes in 761849 ms). 2018-09-17 15:39:36,113 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 3 @ 1537198775941 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:40:08,511 INFO com.amazon.ws.emr.hadoop.fs.s3n.MultipartUploadOutputStream - close closed:false s3://my-test/analytics_streaming_state/8f9ab122fb7452714465eb1e1989e4d7/chk-3/_metadata 2018-09-17 15:40:13,641 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Completed checkpoint 3 for job 8f9ab122fb7452714465eb1e1989e4d7 (1468080105 bytes in 32686 ms). 2018-09-17 15:40:23,771 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Triggering checkpoint 4 @ 1537198823640 for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:41:27,805 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (25914cb3f77c8e4271b0fb6ea597ed50) switched from RUNNING to FAILED. java.lang.IllegalStateException: Writer has already been opened at org.apache.flink.streaming.connectors.fs.StreamWriterBase.open(StreamWriterBase.java:68) at org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter.open(AvroKeyValueSinkWriter.java:150) at org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.openNewPartFile(BucketingSink.java:583) at org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.invoke(BucketingSink.java:458) at org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(SinkFunction.java:52) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202) at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:104) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:306) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:703) at java.lang.Thread.run(Thread.java:748) 2018-09-17 15:41:27,808 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) switched from state RUNNING to FAILING. java.lang.IllegalStateException: Writer has already been opened at org.apache.flink.streaming.connectors.fs.StreamWriterBase.open(StreamWriterBase.java:68) at org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter.open(AvroKeyValueSinkWriter.java:150) at org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.openNewPartFile(BucketingSink.java:583) at org.apache.flink.streaming.connectors.fs.bucketing.BucketingSink.invoke(BucketingSink.java:458) at org.apache.flink.streaming.api.functions.sink.SinkFunction.invoke(SinkFunction.java:52) at org.apache.flink.streaming.api.operators.StreamSink.processElement(StreamSink.java:56) at org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:202) at org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:104) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:306) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:703) at java.lang.Thread.run(Thread.java:748) 2018-09-17 15:41:27,815 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (99ce4cfd3c0c8b43f83004dc0db41f7b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,828 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (d3775a65bbe832cd4959db13cb3b5743) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (56982bebad5da8c4f2989b6c49ad62c9) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (1/16) (e16b36756729da529ba33ff0fd871df6) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (2/16) (ba5cb8abf132b51233fe2c125a9b1c49) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (3/16) (87e8af80bdb34197d891752570318753) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (4/16) (d592daa640e08de3bd8fbae17cd54d39) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (5/16) (692ad1144f5167f0802f8fe1a4289f35) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (6/16) (ffce25842ab2e82b71f97229225ac015) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,829 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (7/16) (c65a9af6cb93cbf325ac5399721922bb) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (8/16) (e542692f4650a01fc3fab27adb15d89b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (9/16) (c3f49133206abb7574a241fac87d5040) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (10/16) (3c4b41cf0ad4093476a022a817f563c7) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (11/16) (d2b24c10bcf9a38b5883aaf84affb762) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (12/16) (2bf7a7cd9b973e1f2021bfc225d967d6) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (13/16) (65f8081b6d9d6089172abcc1d03208fd) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,830 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (14/16) (ac997fd3a0b470d66064ed17fd53f445) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (15/16) (60c6361786268e056f8d93c8fa97e730) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (16/16) (6b592ac9803a3a8cfc22843cc43df1d2) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (e22f0b124f47d6d40d964abf6a05b556) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (f9cd15d98d13ebb84db0e5001e1ff279) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (5a501051ec38450ae41f0a954253680d) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (52954a6d00a5dc0fbc720573a86f0178) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (10cfb3622d8991fe3e121a7b04635532) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,831 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (fbfafe2ad41dba842be581e93f9d734b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (85ded6090632764297adefe2f67d03e2) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (519422fdce76dd4e935eacefe9ffb5af) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (56be5e5097ccf9ae90ed3e7d98fbfc7a) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (bdeaf70e5c3291e02f5e9f5a85851fa1) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (8ec8c6830b08c3558a13083be4529896) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (ed2994c505c46cf1fd9248389544c15f) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (8dffad28a951698dbb5aad4f4d60d315) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,832 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (41c982ca99b29a7574747cdccbde3465) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (ee1d6509eca8c1ebd8cbfc26cd1f1812) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (1447440a5f6a2da2a79408d72fae6b71) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (1/16) (d3f0bcfb034a74237500ee3d9455407c) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (2/16) (349778e54003fbab873d582cf654883d) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (3/16) (7b59c470d766dc384d75de2727ec78b3) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (4/16) (50282ff30e2e25eaa1d16a32b1a66ed5) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (5/16) (b6f8f2f01f610ba0c5e885439b59808b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,833 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (6/16) (ea1fb9efb6aacad4fb52b7e9abc72de9) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (7/16) (20f1ca859fb0ccb85ae1cb38caba0dae) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (8/16) (751aa99cae95bc90ff58f5f9902990fd) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (9/16) (8f8db004c75b8f5388d04210aa3b3a5b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (10/16) (2a15393cb7f5b87dd4c2b62e874ae3e9) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (11/16) (0e60588370d8083878400fb917b0f0e3) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (12/16) (455c4019a2e5eeabd62118f6e0068658) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (13/16) (03dec6dc3d1920a25eafe7816f6d272c) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (14/16) (5a6bb8000145d95fb9338ee871204f4b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,834 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (15/16) (3f6ed92bfb4e35c0ee7913a16c94ea2f) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (16/16) (9be0d2be1a1d64929609aa3626e3c096) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (1/16) (ad8b7610719398e6661ed03ea9d55e8d) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (2/16) (4f76ec6f3d92b7e0accd6dda9af695d5) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (3/16) (f8e59fa9b92365713ca1003f31f60a5f) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (4/16) (38ee7856035c56fd54c0ab03d87610b0) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (5/16) (ba1c7247efbf8ddc093020a43492ac63) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (6/16) (cdbc411bbe1461dc1e151b0105b8dea4) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (7/16) (e08a04b23e885bbd5c0363df2ea944b5) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,835 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (8/16) (feb10daaf620dfb461916d6508c0066c) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (9/16) (994fb1ef8ec7a7e97cb77aa0c5dc14b3) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (10/16) (13f1312c3d7c0ef824bb5801377fb807) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (11/16) (3cafa94cd0732a7443aaa3d9cb046efa) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (12/16) (b5f01b06c630b5609ca5a6e3ebfc1cb2) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (13/16) (84ea7e5125e2cab4427cbcbb47198767) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (14/16) (6c6fe6e4d08a6fde40624c5f993a26e8) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (15/16) (77a0b8c3a9baef3e4cb350b6cf6b4317) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (16/16) (1c84ecb045fa02a89c1871073e046268) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (ce49668d2432c58fea42c159e6aaec1d) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,836 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (aab864b0c40acde6b181a97c9e310867) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (8bd71ccacd283e6d511293fd51b9fa22) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (4e9d509115ada93455be83a85283c42f) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (ce8ea1bf6fae6d4dfa85b12bd9caa040) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (cdc6a260439ebbc2b7b4defe2c6c8ef3) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (3f7f254aa98a77c914a1877cbaad5522) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (458c92f027dd6636147849558dac7a78) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (d6c44653bc3a6030275b3628e3241d48) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (a0fd3658b0867d272cc3e76d4a20af99) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,837 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (fd9b6f428728680594f77d8f85cef185) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (2f9b2076fccb53a33b98ed611f7ebcc2) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (161842846ef8427eff483fb1ebce7581) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (c29c19668ccf95aa1803a737f1dc3476) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (374a1709ed58170599e990b58b96fe37) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (fa99e20e4c77f2b0aa49115a3d1b9bca) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (1/16) (fbe708927873981fe2ff01135498a8e7) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (2/16) (93f9ccde3c0a7bd2f0d0dd131badd18b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (3/16) (f69f15226d7a769c87f2e5ecdaed2989) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,838 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (4/16) (9de77250fded2ebfac860e9ab7269144) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (5/16) (840034a18950d275976e64f818953438) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (6/16) (e26a900ff19da26bfb5e0a4501ce5772) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (7/16) (de42d0da18524c412616bba4ef4b7813) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (8/16) (0d89a0029831150b3823eaa059a9b9d0) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (9/16) (8da157d2d887d3d3f38f65a45df8a575) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (10/16) (77716853f28cbc147052907f60b2375d) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (11/16) (d9e1cbd5a899f8415b862ce5b9363dfc) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,839 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (12/16) (07a08b6b1e52143c4492b2f194e30856) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (13/16) (f163536b17f737dfe1e3399e4a256485) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (14/16) (7a1717f2467f317724dcef4a4519ee36) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (15/16) (2eafc95c8d2e50436b1d223a9099ad2c) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (16/16) (8f8a18d13cc30ef9193fd917bfcc03bc) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (603e0d160161de28eb53ed4342c6e19b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (5d2e73c821bae604f8eba874e7f68415) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,840 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (f19b25325085df39884a0a2dd88e8ce4) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (72e64a9b4d6c8071c13c1114055ecb4e) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (60abd0b940901df1c9be682a7b290b8c) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (6ee163d12edf35e90530ef18fbb07bd3) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (d413f07d38a55becac18329b2173c6ec) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (8bf5ecae8d69e79cd8d3871c2c55c403) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (f89aacf4f37e5aa4c3c7a99df680cfbe) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (dfbb49fd9238b1eb37180adc30fe2291) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (9c25da5c24e51605a70728b2753bb850) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (b640048a4d3d9eed6ab899bab9509d05) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,841 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (6d922d30cdee1ef1bf95af3b2178b303) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,842 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (10e0c5a5a39528ed2a3fd13f2f3e463b) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,842 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (16ad7eb74c12c5bb6909f902af5900cd) switched from RUNNING to CANCELING. 2018-09-17 15:41:27,847 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (b640048a4d3d9eed6ab899bab9509d05) switched from CANCELING to CANCELED. 2018-09-17 15:41:27,848 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (9c25da5c24e51605a70728b2753bb850) switched from CANCELING to CANCELED. 2018-09-17 15:41:27,849 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (72e64a9b4d6c8071c13c1114055ecb4e) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,070 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (6ee163d12edf35e90530ef18fbb07bd3) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,071 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (9/16) (56be5e5097ccf9ae90ed3e7d98fbfc7a) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,072 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (15/16) (60c6361786268e056f8d93c8fa97e730) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,072 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (12/16) (2bf7a7cd9b973e1f2021bfc225d967d6) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,073 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (603e0d160161de28eb53ed4342c6e19b) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,073 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (9/16) (c3f49133206abb7574a241fac87d5040) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,074 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (10/16) (3c4b41cf0ad4093476a022a817f563c7) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,075 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (6d922d30cdee1ef1bf95af3b2178b303) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,076 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (14/16) (ac997fd3a0b470d66064ed17fd53f445) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,076 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (16/16) (6b592ac9803a3a8cfc22843cc43df1d2) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,076 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (13/16) (65f8081b6d9d6089172abcc1d03208fd) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,080 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (11/16) (d2b24c10bcf9a38b5883aaf84affb762) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,080 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/flume/avro/enrollment_log/ (1/1) (99ce4cfd3c0c8b43f83004dc0db41f7b) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,080 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/1) (d3775a65bbe832cd4959db13cb3b5743) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,081 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (9/16) (8f8db004c75b8f5388d04210aa3b3a5b) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,082 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (f89aacf4f37e5aa4c3c7a99df680cfbe) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,082 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (10/16) (2a15393cb7f5b87dd4c2b62e874ae3e9) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,093 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (16/16) (9be0d2be1a1d64929609aa3626e3c096) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,093 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (14/16) (5a6bb8000145d95fb9338ee871204f4b) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,094 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (10/16) (bdeaf70e5c3291e02f5e9f5a85851fa1) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,094 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (1/16) (ce49668d2432c58fea42c159e6aaec1d) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,094 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (13/16) (03dec6dc3d1920a25eafe7816f6d272c) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,095 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (13/16) (161842846ef8427eff483fb1ebce7581) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,100 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (14/16) (c29c19668ccf95aa1803a737f1dc3476) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,100 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (13/16) (8dffad28a951698dbb5aad4f4d60d315) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,101 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (12/16) (455c4019a2e5eeabd62118f6e0068658) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,101 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (12/16) (2f9b2076fccb53a33b98ed611f7ebcc2) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,101 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (11/16) (0e60588370d8083878400fb917b0f0e3) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,102 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (15/16) (3f6ed92bfb4e35c0ee7913a16c94ea2f) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,102 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (16/16) (1447440a5f6a2da2a79408d72fae6b71) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,102 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (12/16) (ed2994c505c46cf1fd9248389544c15f) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,103 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (2/16) (aab864b0c40acde6b181a97c9e310867) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,103 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (15/16) (ee1d6509eca8c1ebd8cbfc26cd1f1812) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,104 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (5/16) (ce8ea1bf6fae6d4dfa85b12bd9caa040) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,104 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (11/16) (8ec8c6830b08c3558a13083be4529896) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,104 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (7/16) (3f7f254aa98a77c914a1877cbaad5522) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,105 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (14/16) (7a1717f2467f317724dcef4a4519ee36) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,109 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (5/16) (840034a18950d275976e64f818953438) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,110 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (10/16) (a0fd3658b0867d272cc3e76d4a20af99) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,115 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (2/16) (93f9ccde3c0a7bd2f0d0dd131badd18b) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,126 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (12/16) (07a08b6b1e52143c4492b2f194e30856) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,137 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (7/16) (de42d0da18524c412616bba4ef4b7813) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,149 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (10/16) (77716853f28cbc147052907f60b2375d) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,160 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (13/16) (f163536b17f737dfe1e3399e4a256485) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,171 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (1/16) (fbe708927873981fe2ff01135498a8e7) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,346 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (14/16) (41c982ca99b29a7574747cdccbde3465) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,433 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (6/16) (cdbc411bbe1461dc1e151b0105b8dea4) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,671 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (13/16) (84ea7e5125e2cab4427cbcbb47198767) switched from CANCELING to CANCELED. 2018-09-17 15:41:29,907 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (12/16) (b5f01b06c630b5609ca5a6e3ebfc1cb2) switched from CANCELING to CANCELED. 2018-09-17 15:41:30,144 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (9/16) (994fb1ef8ec7a7e97cb77aa0c5dc14b3) switched from CANCELING to CANCELED. 2018-09-17 15:41:30,392 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (1/16) (ad8b7610719398e6661ed03ea9d55e8d) switched from CANCELING to CANCELED. 2018-09-17 15:41:30,627 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (10/16) (13f1312c3d7c0ef824bb5801377fb807) switched from CANCELING to CANCELED. 2018-09-17 15:41:30,863 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (8/16) (feb10daaf620dfb461916d6508c0066c) switched from CANCELING to CANCELED. 2018-09-17 15:41:33,309 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/flume/avro/enrollment_log/ (1/1) (56982bebad5da8c4f2989b6c49ad62c9) switched from CANCELING to CANCELED. 2018-09-17 15:41:34,944 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (7/16) (e08a04b23e885bbd5c0363df2ea944b5) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,046 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (8/16) (519422fdce76dd4e935eacefe9ffb5af) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,047 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (2/16) (f9cd15d98d13ebb84db0e5001e1ff279) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,047 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (1/16) (e22f0b124f47d6d40d964abf6a05b556) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,048 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (7/16) (85ded6090632764297adefe2f67d03e2) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,048 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (4/16) (50282ff30e2e25eaa1d16a32b1a66ed5) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,049 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (7/16) (c65a9af6cb93cbf325ac5399721922bb) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,049 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (6/16) (ffce25842ab2e82b71f97229225ac015) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,050 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (2/16) (ba5cb8abf132b51233fe2c125a9b1c49) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,050 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (1/16) (e16b36756729da529ba33ff0fd871df6) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,050 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (8/16) (e542692f4650a01fc3fab27adb15d89b) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,051 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (2/16) (349778e54003fbab873d582cf654883d) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,053 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (3/16) (7b59c470d766dc384d75de2727ec78b3) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,054 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (5/16) (692ad1144f5167f0802f8fe1a4289f35) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,054 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (4/16) (d592daa640e08de3bd8fbae17cd54d39) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,055 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Filter (3/16) (87e8af80bdb34197d891752570318753) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,055 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (3/16) (5a501051ec38450ae41f0a954253680d) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,055 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (5/16) (10cfb3622d8991fe3e121a7b04635532) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,056 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (4/16) (52954a6d00a5dc0fbc720573a86f0178) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,056 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (7/16) (20f1ca859fb0ccb85ae1cb38caba0dae) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,057 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (8/16) (751aa99cae95bc90ff58f5f9902990fd) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,057 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (1/16) (d3f0bcfb034a74237500ee3d9455407c) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,057 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (8bd71ccacd283e6d511293fd51b9fa22) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,058 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (6/16) (ea1fb9efb6aacad4fb52b7e9abc72de9) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,058 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (458c92f027dd6636147849558dac7a78) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,059 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (cdc6a260439ebbc2b7b4defe2c6c8ef3) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,059 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Split Reader: s3://my-test/analytics_streaming/enrollment_log_rollup/ (6/16) (fbfafe2ad41dba842be581e93f9d734b) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,060 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Timestamps/Watermarks -> (Filter, Filter) (5/16) (b6f8f2f01f610ba0c5e885439b59808b) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,060 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (fa99e20e4c77f2b0aa49115a3d1b9bca) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,060 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (4e9d509115ada93455be83a85283c42f) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,061 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (fd9b6f428728680594f77d8f85cef185) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,061 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (374a1709ed58170599e990b58b96fe37) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,061 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (d6c44653bc3a6030275b3628e3241d48) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,062 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (6/16) (60abd0b940901df1c9be682a7b290b8c) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,062 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (15/16) (10e0c5a5a39528ed2a3fd13f2f3e463b) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,063 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (8/16) (d413f07d38a55becac18329b2173c6ec) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,063 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (11/16) (dfbb49fd9238b1eb37180adc30fe2291) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,063 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (9/16) (8bf5ecae8d69e79cd8d3871c2c55c403) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,064 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (3/16) (5d2e73c821bae604f8eba874e7f68415) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,064 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (16/16) (16ad7eb74c12c5bb6909f902af5900cd) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,064 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Sink: Unnamed (4/16) (f19b25325085df39884a0a2dd88e8ce4) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,137 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (15/16) (77a0b8c3a9baef3e4cb350b6cf6b4317) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,372 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (2/16) (4f76ec6f3d92b7e0accd6dda9af695d5) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,603 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (11/16) (3cafa94cd0732a7443aaa3d9cb046efa) switched from CANCELING to CANCELED. 2018-09-17 15:41:37,845 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (14/16) (6c6fe6e4d08a6fde40624c5f993a26e8) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,082 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (3/16) (f8e59fa9b92365713ca1003f31f60a5f) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,324 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (4/16) (9de77250fded2ebfac860e9ab7269144) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,325 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (4/16) (38ee7856035c56fd54c0ab03d87610b0) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,339 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (3/16) (f69f15226d7a769c87f2e5ecdaed2989) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,591 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (5/16) (ba1c7247efbf8ddc093020a43492ac63) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,593 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (6/16) (e26a900ff19da26bfb5e0a4501ce5772) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,606 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (8/16) (0d89a0029831150b3823eaa059a9b9d0) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,621 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (16/16) (8f8a18d13cc30ef9193fd917bfcc03bc) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,635 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (11/16) (d9e1cbd5a899f8415b862ce5b9363dfc) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,648 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (9/16) (8da157d2d887d3d3f38f65a45df8a575) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,662 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Chapter ID -> Map (15/16) (2eafc95c8d2e50436b1d223a9099ad2c) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,915 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Get Min Event Time Of Member ID -> Map (16/16) (1c84ecb045fa02a89c1871073e046268) switched from CANCELING to CANCELED. 2018-09-17 15:41:38,915 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Try to restart or fail the job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) if no longer possible. 2018-09-17 15:41:38,915 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) switched from state FAILING to RESTARTING. 2018-09-17 15:41:38,915 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Restarting the job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7). 2018-09-17 15:42:31,839 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{bb51aa436daa6af7d98933e7134a3e8b}]. 2018-09-17 15:42:31,841 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{119fda5a59490bd2444c31b5c9b53d93}]. 2018-09-17 15:42:31,841 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{4f1e9371a775d53cc7cda503c9384632}]. 2018-09-17 15:42:31,841 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{a017455e764988aba83f9f600840bb36}]. 2018-09-17 15:42:31,841 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{f42afdfa223a3e0e69e1485a197419a8}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{29f5c97df94fbe2538d9bce146a3cb1d}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{ecae8f5b5f49f204c4eb1ac7871691c5}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{c6256b7c0ff9ddc289159a9eb4b03f71}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{aa3eeae8be26609a5752de44b3a8fddc}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{a62377cf4d61734c31016ac2ba0cf9a0}]. 2018-09-17 15:42:31,842 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{fc0408b0ecb614ce48eacff7cf478d46}]. 2018-09-17 15:42:31,843 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{105cd9b45ae1ceda99c95c5f188e03bc}]. 2018-09-17 15:42:31,843 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{214d03473f4c4d6024ddee4d96762b9a}]. 2018-09-17 15:42:31,843 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{6a586c690b803f174c90dd6ab0ba4a3c}]. 2018-09-17 15:42:31,843 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{a509190b0782f0c5a4c873b6377c90fc}]. 2018-09-17 15:42:31,844 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Releasing idle slot [AllocationID{5b3c27ade2225b6b66a3bd905eb46d62}]. 2018-09-17 15:43:16,500 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000003. 2018-09-17 15:43:16,526 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000003 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:43:16,526 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager fee9575f3feeef3b1ac634fd100283ae from the SlotManager. 2018-09-17 15:43:16,527 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000002. 2018-09-17 15:43:16,547 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000002 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:43:16,547 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 6e9d624c59632e7cbb65cf3fc853becd from the SlotManager. 2018-09-17 15:43:16,554 WARN org.apache.flink.yarn.YarnResourceManager - Discard registration from TaskExecutor container_1537197527300_0001_01_000003 at (akka.tcp://flink@ip-172-31-41-250.ec2.internal:41825/user/taskmanager_0) because the framework did not recognize it 2018-09-17 15:43:16,556 WARN org.apache.flink.yarn.YarnResourceManager - Discard registration from TaskExecutor container_1537197527300_0001_01_000002 at (akka.tcp://flink@ip-172-31-37-51.ec2.internal:42401/user/taskmanager_0) because the framework did not recognize it 2018-09-17 15:43:16,938 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000005 - Remaining pending container requests: 14 2018-09-17 15:43:17,368 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:43:17,369 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:43:17,383 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000006 - Remaining pending container requests: 13 2018-09-17 15:43:17,402 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:43:17,402 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:43:17,518 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:41825] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:43:17,547 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:42401] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:43:20,264 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000005 under 0e1b0d57c6604f79a42c9b18852d7b9a at the SlotManager. 2018-09-17 15:43:20,318 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000006 under 1a39f0d6f44eef62db98fb5355f96f50 at the SlotManager. 2018-09-17 15:44:16,539 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000006. 2018-09-17 15:44:16,554 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000006 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:44:16,555 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 1a39f0d6f44eef62db98fb5355f96f50 from the SlotManager. 2018-09-17 15:44:16,555 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000005. 2018-09-17 15:44:16,571 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000005 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:44:16,572 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 0e1b0d57c6604f79a42c9b18852d7b9a from the SlotManager. 2018-09-17 15:44:16,881 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:43463] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:44:16,896 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:36853] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:44:17,055 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000007 - Remaining pending container requests: 12 2018-09-17 15:44:17,080 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:44:17,080 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:44:17,089 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000008 - Remaining pending container requests: 11 2018-09-17 15:44:17,107 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:44:17,107 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:44:20,016 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000008 under 5ada69d96a2eaa87fa5370d0f49a9bff at the SlotManager. 2018-09-17 15:44:20,056 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000007 under cc549b06a417ff9cdf4e383c4e6388ce at the SlotManager. 2018-09-17 15:45:16,579 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000008. 2018-09-17 15:45:16,597 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000008 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:45:16,597 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 5ada69d96a2eaa87fa5370d0f49a9bff from the SlotManager. 2018-09-17 15:45:16,597 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000007. 2018-09-17 15:45:16,613 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000007 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:45:16,613 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager cc549b06a417ff9cdf4e383c4e6388ce from the SlotManager. 2018-09-17 15:45:16,674 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000009 - Remaining pending container requests: 10 2018-09-17 15:45:16,707 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:45:16,707 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:45:16,718 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000010 - Remaining pending container requests: 9 2018-09-17 15:45:16,921 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:37159] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:45:16,936 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:37093] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:45:17,139 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:45:17,139 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:45:19,723 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000009 under 28ef7bf2f96b576e9a5a1da23202a8ec at the SlotManager. 2018-09-17 15:45:20,010 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000010 under 932cd3a1cbed4713fe99649c202f8ae5 at the SlotManager. 2018-09-17 15:45:46,602 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job Stream to Stream Join (8f9ab122fb7452714465eb1e1989e4d7) switched from state RESTARTING to CANCELED. 2018-09-17 15:45:46,602 INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 8f9ab122fb7452714465eb1e1989e4d7. 2018-09-17 15:45:46,602 INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down 2018-09-17 15:45:46,602 INFO org.apache.flink.runtime.checkpoint.CompletedCheckpoint - Checkpoint with ID 3 at 's3://my-test/analytics_streaming_state/8f9ab122fb7452714465eb1e1989e4d7/chk-3' not discarded. 2018-09-17 15:45:46,602 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Canceled during restart. 2018-09-17 15:45:46,604 INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 8f9ab122fb7452714465eb1e1989e4d7 reached globally terminal state CANCELED. 2018-09-17 15:45:46,629 INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job Stream to Stream Join(8f9ab122fb7452714465eb1e1989e4d7). 2018-09-17 15:45:46,630 INFO org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 8c2550b69131061a17207a93758d4a62: JobManager is shutting down.. 2018-09-17 15:45:46,630 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Suspending SlotPool. 2018-09-17 15:45:46,630 INFO org.apache.flink.yarn.YarnResourceManager - Disconnect job manager 00000000000000000000000000000000@akka.tcp://flink@ip-172-31-37-232.ec2.internal:37959/user/jobmanager_0 for job 8f9ab122fb7452714465eb1e1989e4d7 from the resource manager. 2018-09-17 15:45:46,630 INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPool - Stopping SlotPool. 2018-09-17 15:45:46,631 INFO org.apache.flink.runtime.jobmaster.JobManagerRunner - JobManagerRunner already shutdown. 2018-09-17 15:46:16,620 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000010. 2018-09-17 15:46:16,637 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000010 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:46:16,637 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 932cd3a1cbed4713fe99649c202f8ae5 from the SlotManager. 2018-09-17 15:46:16,637 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000009. 2018-09-17 15:46:16,654 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000009 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:46:16,654 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 28ef7bf2f96b576e9a5a1da23202a8ec from the SlotManager. 2018-09-17 15:46:16,792 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000011 - Remaining pending container requests: 8 2018-09-17 15:46:16,957 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.37.51:48436] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:46:16,957 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:42311] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:46:16,976 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.41.250:50148] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:46:16,977 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:42375] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:46:17,224 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:46:17,224 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:46:17,233 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000012 - Remaining pending container requests: 7 2018-09-17 15:46:17,652 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:46:17,652 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:46:20,119 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000011 under 817bd749b2284162a2768eb29a2b2937 at the SlotManager. 2018-09-17 15:46:20,556 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000012 under 13b0715af4b36ba507d6a3fe9b9c3025 at the SlotManager. 2018-09-17 15:46:38,918 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Canceled job during restart. Aborting restart. 2018-09-17 15:46:51,074 INFO org.apache.flink.runtime.blob.BlobClient - Downloading null/t-b78eb79e3aa0e3360b51721c8f3a24b7f5d2e4f6-13f974c363c5898da894e210fc894cca from ip-172-31-37-232.ec2.internal/172.31.37.232:43215 2018-09-17 15:47:16,659 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000011. 2018-09-17 15:47:16,674 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000011 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:47:16,674 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 817bd749b2284162a2768eb29a2b2937 from the SlotManager. 2018-09-17 15:47:16,674 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000012. 2018-09-17 15:47:16,691 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000012 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:47:16,691 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager 13b0715af4b36ba507d6a3fe9b9c3025 from the SlotManager. 2018-09-17 15:47:16,902 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000013 - Remaining pending container requests: 6 2018-09-17 15:47:16,924 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:47:16,924 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:47:16,935 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000014 - Remaining pending container requests: 5 2018-09-17 15:47:16,995 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.37.51:48468] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:47:16,995 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:32897] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:47:17,010 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.41.250:50184] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:47:17,010 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:34173] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:47:17,353 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:47:17,353 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:47:19,790 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000013 under cff0406e05763466bbcff511b9c0d970 at the SlotManager. 2018-09-17 15:47:20,259 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000014 under c700970b847ed18b866f1f2ae71e7b22 at the SlotManager. 2018-09-17 15:48:16,699 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000013. 2018-09-17 15:48:16,711 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000013 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:48:16,711 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager cff0406e05763466bbcff511b9c0d970 from the SlotManager. 2018-09-17 15:48:16,712 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000014. 2018-09-17 15:48:16,723 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000014 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:48:16,723 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager c700970b847ed18b866f1f2ae71e7b22 from the SlotManager. 2018-09-17 15:48:17,019 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000015 - Remaining pending container requests: 4 2018-09-17 15:48:17,029 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.37.51:48506] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:48:17,030 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:33497] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:48:17,042 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:33259] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:48:17,443 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:48:17,443 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:48:17,452 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000016 - Remaining pending container requests: 3 2018-09-17 15:48:17,871 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:48:17,871 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:48:20,272 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000015 under fa0faf166e6ffc1b5ec7f2277d14847f at the SlotManager. 2018-09-17 15:48:20,763 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000016 under d135bf10fe6755ec8eb37f5682e831d0 at the SlotManager. 2018-09-17 15:49:16,739 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000015. 2018-09-17 15:49:16,751 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000015 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:49:16,751 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager fa0faf166e6ffc1b5ec7f2277d14847f from the SlotManager. 2018-09-17 15:49:16,751 INFO org.apache.flink.yarn.YarnResourceManager - Stopping container container_1537197527300_0001_01_000016. 2018-09-17 15:49:16,766 INFO org.apache.flink.yarn.YarnResourceManager - Closing TaskExecutor connection container_1537197527300_0001_01_000016 because: TaskExecutor exceeded the idle timeout. 2018-09-17 15:49:16,767 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Unregister TaskManager d135bf10fe6755ec8eb37f5682e831d0 from the SlotManager. 2018-09-17 15:49:17,067 WARN akka.remote.transport.netty.NettyTransport - Remote connection to [/172.31.37.51:48558] failed with java.io.IOException: Connection reset by peer 2018-09-17 15:49:17,068 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-37-51.ec2.internal:34171] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:49:17,085 WARN akka.remote.ReliableDeliverySupervisor - Association with remote system [akka.tcp://flink@ip-172-31-41-250.ec2.internal:45965] has failed, address is now gated for [50] ms. Reason: [Disassociated] 2018-09-17 15:49:17,127 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000017 - Remaining pending container requests: 2 2018-09-17 15:49:17,549 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:49:17,550 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:49:17,558 INFO org.apache.flink.yarn.YarnResourceManager - Received new container: container_1537197527300_0001_01_000018 - Remaining pending container requests: 1 2018-09-17 15:49:17,979 INFO org.apache.flink.yarn.YarnResourceManager - Creating container launch context for TaskManagers 2018-09-17 15:49:17,979 INFO org.apache.flink.yarn.YarnResourceManager - Starting TaskManagers 2018-09-17 15:49:20,365 INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManager - Registering TaskManager container_1537197527300_0001_01_000017 under efcd8a14619cf3bf6aec21b5d66d125d at the SlotManager.