SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/usr/hdp/2.4.0.0-169/hadoop/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/usr/hdp/2.4.0.0-169/zookeeper/lib/slf4j-log4j12-1.6.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/root/apache-kylin-1.5.2.1/lib/kylin-job-1.5.2.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/root/apache-kylin-1.5.2.1/lib/kylin-jdbc-1.5.2.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation.
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
2016-08-15 09:45:39,934 WARN  [main StreamingCLI:84]: ignore this arg:Streaming_Cube
2016-08-15 09:45:39,943 WARN  [main StreamingCLI:84]: ignore this arg:1471254300000_1471254600000
2016-08-15 09:45:40,017 WARN  [main KylinConfig:163]: KYLIN_CONF property was not set, will seek KYLIN_HOME env variable
2016-08-15 09:45:40,060 INFO  [main CubeManager:122]: Initializing CubeManager with config kylin_metadata@hbase
2016-08-15 09:45:40,083 INFO  [main ResourceStore:82]: Using metadata url kylin_metadata@hbase for resource store
2016-08-15 09:45:41,363 INFO  [main HBaseConnection:142]: connection is null or closed, creating a new one
2016-08-15 09:45:42,574 INFO  [main RecoverableZooKeeper:120]: Process identifier=hconnection-0x720f1977 connecting to ZooKeeper ensemble=sandbox.hortonworks.com:2181
2016-08-15 09:45:42,589 INFO  [main ZooKeeper:100]: Client environment:zookeeper.version=3.4.6-169--1, built on 02/10/2016 05:49 GMT
2016-08-15 09:45:42,590 INFO  [main ZooKeeper:100]: Client environment:host.name=sandbox.hortonworks.com
2016-08-15 09:45:42,591 INFO  [main ZooKeeper:100]: Client environment:java.version=1.7.0_95
2016-08-15 09:45:42,591 INFO  [main ZooKeeper:100]: Client environment:java.vendor=Oracle Corporation
2016-08-15 09:45:42,591 INFO  [main ZooKeeper:100]: Client environment:java.home=/usr/lib/jvm/java-1.7.0-openjdk-1.7.0.95.x86_64/jre
2016-08-15 09:45:42,592 INFO  [main ZooKeeper:100]: Client environment:java.class.path=/usr/hdp/2.4.0.0-169/hbase/conf:/usr/lib/jvm/java/lib/tools.jar:/usr/hdp/2.4.0.0-169/hbase:/usr/hdp/2.4.0.0-169/hbase/lib/activation-1.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/aopalliance-1.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/apacheds-i18n-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hbase/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hbase/lib/api-asn1-api-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hbase/lib/api-util-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hbase/lib/asm-3.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-beanutils-1.7.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-beanutils-core-1.8.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-codec-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-configuration-1.6.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-daemon-1.0.13.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-digester-1.8.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-el-1.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-httpclient-3.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-logging-1.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-math-2.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/commons-net-3.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/curator-client-2.7.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/curator-framework-2.7.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/curator-recipes-2.7.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/disruptor-3.3.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/findbugs-annotations-1.3.9-1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hbase/lib/guava-12.0.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/guice-3.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/guice-servlet-3.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-annotations-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-annotations-1.1.2.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-annotations.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-client-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-client.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-common-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-common-1.1.2.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-common.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-examples-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-examples.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-hadoop2-compat-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-hadoop2-compat.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-hadoop-compat-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-hadoop-compat.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-it-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-it-1.1.2.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-it.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-prefix-tree-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-prefix-tree.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-procedure-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-procedure.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-protocol-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-protocol.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-resource-bundle-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-resource-bundle.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-rest-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-rest.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-server-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-server-1.1.2.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-server.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-shell-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-shell.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-thrift-1.1.2.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/hbase-thrift.jar:/usr/hdp/2.4.0.0-169/hbase/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hbase/lib/httpclient-4.2.5.jar:/usr/hdp/2.4.0.0-169/hbase/lib/httpcore-4.2.5.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jackson-core-2.2.3.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jackson-xc-1.9.13.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jamon-runtime-2.3.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jasper-compiler-5.5.23.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jasper-runtime-5.5.23.jar:/usr/hdp/2.4.0.0-169/hbase/lib/javax.inject-1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/java-xmlbuilder-0.4.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jaxb-api-2.2.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jcodings-1.0.8.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jersey-client-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jersey-guice-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jets3t-0.9.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jettison-1.3.3.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jetty-sslengine-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hbase/lib/joni-2.1.2.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jruby-complete-1.6.8.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jsch-0.1.42.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jsp-2.1-6.1.14.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jsp-api-2.1-6.1.14.jar:/usr/hdp/2.4.0.0-169/hbase/lib/jsr305-1.3.9.jar:/usr/hdp/2.4.0.0-169/hbase/lib/junit-4.11.jar:/usr/hdp/2.4.0.0-169/hbase/lib/leveldbjni-all-1.8.jar:/usr/hdp/2.4.0.0-169/hbase/lib/libthrift-0.9.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hbase/lib/metrics-core-2.2.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/microsoft-windowsazure-storage-sdk-0.6.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/hbase/lib/netty-3.2.4.Final.jar:/usr/hdp/2.4.0.0-169/hbase/lib/netty-all-4.0.23.Final.jar:/usr/hdp/2.4.0.0-169/hbase/lib/ojdbc6.jar:/usr/hdp/2.4.0.0-169/hbase/lib/okhttp-2.4.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/okio-1.4.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hbase/lib/phoenix-server.jar:/usr/hdp/2.4.0.0-169/hbase/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/ranger-hbase-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/ranger-plugin-classloader-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hbase/lib/servlet-api-2.5-6.1.14.jar:/usr/hdp/2.4.0.0-169/hbase/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hbase/lib/slf4j-api-1.7.7.jar:/usr/hdp/2.4.0.0-169/hbase/lib/snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/spymemcached-2.11.6.jar:/usr/hdp/2.4.0.0-169/hbase/lib/xercesImpl-2.9.1.jar:/usr/hdp/2.4.0.0-169/hbase/lib/xml-apis-1.3.04.jar:/usr/hdp/2.4.0.0-169/hbase/lib/xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hbase/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hbase/lib/zookeeper.jar:/usr/hdp/2.4.0.0-169/hadoop/conf:/usr/hdp/2.4.0.0-169/hadoop/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jaxb-api-2.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-digester-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsch-0.1.42.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-xc-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsp-api-2.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/httpcore-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jettison-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jets3t-0.9.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/api-asn1-api-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-net-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/junit-4.11.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/activation-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-framework-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-core-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/slf4j-api-1.7.10.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/slf4j-log4j12-1.7.10.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/microsoft-windowsazure-storage-sdk-0.6.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-beanutils-core-1.8.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/apacheds-i18n-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ojdbc6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-configuration-1.6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/httpclient-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/azure-storage-2.2.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/hamcrest-core-1.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-beanutils-1.7.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-httpclient-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-databind-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/api-util-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/stax-api-1.0-2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-recipes-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/aws-java-sdk-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-hdfs-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-plugin-classloader-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-annotations-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/java-xmlbuilder-0.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-yarn-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/mockito-all-1.8.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-client-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/spark-yarn-shuffle.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsr305-3.0.0.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-auth.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-common.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-annotations.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-annotations-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-aws.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-common-2.7.1.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-common-tests.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-aws-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-auth-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-nfs.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-azure.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-azure-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/.//hadoop-nfs-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/./:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/netty-all-4.0.23.Final.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/xercesImpl-2.9.1.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/xml-apis-1.3.04.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-daemon-1.0.13.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/okhttp-2.4.0.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/okio-1.4.0.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/jsr305-3.0.0.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/lib/leveldbjni-all-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs-nfs-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs-2.7.1.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs-nfs.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-hdfs/.//hadoop-hdfs.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jaxb-api-2.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-digester-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jsch-0.1.42.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-xc-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/zookeeper-3.4.6.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jsp-api-2.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/httpcore-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/aopalliance-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jettison-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jets3t-0.9.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/api-asn1-api-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-net-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/activation-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/curator-framework-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-core-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/guice-servlet-3.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jersey-guice-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/javassist-3.18.1-GA.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/fst-2.24.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/microsoft-windowsazure-storage-sdk-0.6.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-beanutils-core-1.8.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/apacheds-i18n-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-configuration-1.6.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/httpclient-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/javax.inject-1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jersey-client-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/objenesis-2.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/guice-3.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-beanutils-1.7.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-httpclient-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-databind-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/api-util-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/stax-api-1.0-2.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/curator-recipes-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jackson-annotations-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/java-xmlbuilder-0.4.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/curator-client-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/jsr305-3.0.0.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/lib/leveldbjni-all-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-api.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-common.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-client-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-web-proxy.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-registry.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-tests-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-resourcemanager.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-timeline-plugins.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-web-proxy-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-resourcemanager-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-applicationhistoryservice-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-applicationhistoryservice.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-sharedcachemanager.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-nodemanager-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-applications-unmanaged-am-launcher.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-applications-unmanaged-am-launcher-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-applications-distributedshell.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-sharedcachemanager-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-api-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-nodemanager.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-applications-distributedshell-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-client.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-common.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-timeline-plugins-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-server-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-yarn/.//hadoop-yarn-registry-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/aopalliance-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/junit-4.11.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/guice-servlet-3.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/jersey-guice-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/javax.inject-1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/guice-3.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/hamcrest-core-1.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/lib/leveldbjni-all-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-hs-plugins.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jaxb-api-2.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-digester-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jsch-0.1.42.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jackson-xc-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jsp-api-2.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-auth.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//httpcore-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-rumen.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-jobclient-2.7.1.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jettison-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jets3t-0.9.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//apacheds-kerberos-codec-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//api-asn1-api-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-net-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jaxb-impl-2.2.3-1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-ant-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//junit-4.11.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//activation-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//curator-framework-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jackson-jaxrs-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-core-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-hs.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-extras-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-shuffle-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-extras.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jackson-core-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//microsoft-windowsazure-storage-sdk-0.6.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-beanutils-core-1.8.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//apacheds-i18n-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-streaming-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-configuration-1.6.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-distcp.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//httpclient-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-hs-plugins-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-app-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-jobclient-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-archives.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-distcp-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-hs-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-streaming.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-ant.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hamcrest-core-1.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-datajoin-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-datajoin.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-beanutils-1.7.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-examples.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-httpclient-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-lang3-3.3.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//api-util-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//stax-api-1.0-2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-archives-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-sls.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-sls-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-app.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-core.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-common.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-auth-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//curator-recipes-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-rumen-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-examples-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//xz-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-shuffle.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//java-xmlbuilder-0.4.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-jobclient-tests.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//joda-time-2.9.2.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//mockito-all-1.8.5.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-mapreduce-client-jobclient.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//curator-client-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-gridmix-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-gridmix.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//metrics-core-3.0.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-openstack.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//hadoop-openstack-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop-mapreduce/.//jsr305-3.0.0.jar::mysql-connector-java-5.1.17.jar:mysql-connector-java-5.1.31-bin.jar:mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/tez/tez-runtime-internals-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-mapreduce-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-yarn-timeline-history-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-history-parser-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-dag-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-runtime-library-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-examples-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-common-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-yarn-timeline-cache-plugin-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-yarn-timeline-history-with-fs-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-api-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-tests-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/tez-yarn-timeline-history-with-acls-0.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/jettison-1.3.4.jar:/usr/hdp/2.4.0.0-169/tez/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/tez/lib/jsr305-2.0.3.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-mapreduce-client-core-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-yarn-server-web-proxy-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/tez/lib/slf4j-api-1.7.5.jar:/usr/hdp/2.4.0.0-169/tez/lib/guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/tez/lib/jersey-client-1.9.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-annotations-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-mapreduce-client-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-aws-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-collections4-4.1.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/tez/lib/jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/tez/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/tez/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-azure-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/lib/hadoop-yarn-server-timeline-plugins-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/tez/conf:/usr/hdp/2.4.0.0-169/hadoop/conf:/usr/hdp/2.4.0.0-169/hadoop/hadoop-auth.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-common.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-annotations.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-annotations-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-aws.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-common-2.7.1.2.4.0.0-169-tests.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-common-tests.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-aws-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-common-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-auth-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-nfs.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-azure.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-azure-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/hadoop-nfs-2.7.1.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jetty-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jaxb-api-2.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-digester-1.8.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsch-0.1.42.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-xc-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsp-api-2.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/httpcore-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jettison-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jets3t-0.9.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/api-asn1-api-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-net-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/junit-4.11.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/activation-1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-framework-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-core-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-core-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/slf4j-api-1.7.10.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/log4j-1.2.17.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/slf4j-log4j12-1.7.10.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/microsoft-windowsazure-storage-sdk-0.6.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-beanutils-core-1.8.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/apacheds-i18n-2.0.0-M15.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jetty-util-6.1.26.hwx.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ojdbc6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-configuration-1.6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-math3-3.1.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/httpclient-4.2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/guava-11.0.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/azure-storage-2.2.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/asm-3.2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/netty-3.6.2.Final.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/hamcrest-core-1.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-beanutils-1.7.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-httpclient-3.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-databind-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/api-util-1.0.0-M20.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/stax-api-1.0-2.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-recipes-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/xmlenc-0.52.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/aws-java-sdk-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-hdfs-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-plugin-classloader-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jackson-annotations-2.2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-json-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/avro-1.7.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/java-xmlbuilder-0.4.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/ranger-yarn-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/mockito-all-1.8.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/curator-client-2.7.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/spark-yarn-shuffle.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/snappy-java-1.0.4.1.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jersey-server-1.9.jar:/usr/hdp/2.4.0.0-169/hadoop/lib/jsr305-3.0.0.jar:/usr/hdp/2.4.0.0-169/zookeeper/zookeeper.jar:/usr/hdp/2.4.0.0-169/zookeeper/zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/nekohtml-1.9.6.2.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-plugin-registry-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/classworlds-1.1-alpha-2.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-settings-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/commons-codec-1.6.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/ant-1.8.0.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-profile-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-http-lightweight-1.0-beta-6.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/ant-launcher-1.8.0.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-http-shared-1.0-beta-6.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-provider-api-2.4.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/commons-logging-1.1.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-ant-tasks-2.1.3.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/httpclient-4.2.3.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-project-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/commons-io-2.2.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-http-shared4-2.4.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/httpcore-4.2.3.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/xercesMinimal-1.9.6.2.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-http-2.4.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/plexus-utils-3.0.8.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/slf4j-api-1.6.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/plexus-container-default-1.0-alpha-9-stable-1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/jline-0.9.94.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/jsoup-1.7.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/slf4j-log4j12-1.6.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/log4j-1.2.16.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-error-diagnostics-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-artifact-manager-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-model-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-repository-metadata-2.2.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/netty-3.7.0.Final.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/wagon-file-1.0-beta-6.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/backport-util-concurrent-3.1.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/plexus-interpolation-1.11.jar:/usr/hdp/2.4.0.0-169/zookeeper/lib/maven-artifact-2.2.1.jar:/usr/hdp/current/hive-client/conf:/usr/hdp/2.4.0.0-169/hive/lib/maven-scm-provider-svn-commons-1.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/stax-api-1.0.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/jcommander-1.32.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-service.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-beeline-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-ant.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-hbase-handler.jar:/usr/hdp/2.4.0.0-169/hive/lib/derby-10.10.2.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/pentaho-aggdesigner-algorithm-5.1.5-jhyde.jar:/usr/hdp/2.4.0.0-169/hive/lib/accumulo-start-1.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/jetty-all-7.6.0.v20120127.jar:/usr/hdp/2.4.0.0-169/hive/lib/mail-1.4.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/opencsv-2.3.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-ant-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/geronimo-jta_1.1_spec-1.1.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-accumulo-handler.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-pool-1.5.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/httpclient-4.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/super-csv-2.2.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/stringtemplate-3.2.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-common.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-metastore.jar:/usr/hdp/2.4.0.0-169/hive/lib/parquet-hadoop-bundle-1.6.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/accumulo-core-1.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-cli-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-compress-1.4.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/antlr-runtime-3.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/ivy-2.4.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/jline-2.12.jar:/usr/hdp/2.4.0.0-169/hive/lib/activation-1.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-codec-1.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/ant-launcher-1.9.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-serde.jar:/usr/hdp/2.4.0.0-169/hive/lib/accumulo-fate-1.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/libfb303-0.9.2.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-accumulo-handler-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/avro-1.7.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/eigenbase-properties-1.1.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/jetty-all-server-7.6.0.v20120127.jar:/usr/hdp/2.4.0.0-169/hive/lib/janino-2.7.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/httpmime-4.2.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/ranger-plugins-audit-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/javax.persistence-2.1.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/gson-2.2.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/ranger-hive-plugin-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/noggit-0.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/eclipselink-2.5.2-M1.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/ranger-plugins-common-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/ranger_solrj-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-impl/ranger-plugins-cred-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-scheduler.jar:/usr/hdp/2.4.0.0-169/hive/lib/asm-commons-3.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-exec.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-cli.jar:/usr/hdp/2.4.0.0-169/hive/lib/datanucleus-core-3.2.10.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-contrib-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-beeline.jar:/usr/hdp/2.4.0.0-169/hive/lib/plexus-utils-1.5.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-httpclient-3.0.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/bonecp-0.8.0.RELEASE.jar:/usr/hdp/2.4.0.0-169/hive/lib/geronimo-annotation_1.0_spec-1.1.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/antlr-2.7.7.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-hive-plugin-shim-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ojdbc6.jar:/usr/hdp/2.4.0.0-169/hive/lib/maven-scm-api-1.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/apache-log4j-extras-1.2.17.jar:/usr/hdp/2.4.0.0-169/hive/lib/json-20090211.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-hwi.jar:/usr/hdp/2.4.0.0-169/hive/lib/htrace-core-3.1.0-incubating.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-jdbc.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-logging-1.1.3.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-cli-1.2.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims.jar:/usr/hdp/2.4.0.0-169/hive/lib/maven-scm-provider-svnexe-1.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/geronimo-jaspic_1.0_spec-1.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/httpcore-4.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/snappy-java-1.0.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-common.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-contrib.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-collections-3.2.2.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-serde-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-scheduler-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/mysql-connector-java.jar:/usr/hdp/2.4.0.0-169/hive/lib/datanucleus-rdbms-3.2.9.jar:/usr/hdp/2.4.0.0-169/hive/lib/libthrift-0.9.2.jar:/usr/hdp/2.4.0.0-169/hive/lib/zookeeper-3.4.6.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-hwi-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-dbcp-1.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/oro-2.0.8.jar:/usr/hdp/2.4.0.0-169/hive/lib/protobuf-java-2.5.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/groovy-all-2.1.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-0.23-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-compiler-2.7.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/velocity-1.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-0.20S-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-math-2.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/curator-framework-2.6.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/log4j-1.2.16.jar:/usr/hdp/2.4.0.0-169/hive/lib/curator-client-2.6.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/regexp-1.3.jar:/usr/hdp/2.4.0.0-169/hive/lib/jpam-1.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-io-2.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/asm-tree-3.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/datanucleus-api-jdo-3.2.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/jdo-api-3.0.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/ranger-plugin-classloader-0.5.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-metastore-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/xz-1.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/joda-time-2.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/jta-1.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-vfs2-2.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/ST4-4.0.4.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-shims-common-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/accumulo-trace-1.7.0.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/netty-3.7.0.Final.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-common-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/servlet-api-2.5.jar:/usr/hdp/2.4.0.0-169/hive/lib/curator-recipes-2.6.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/commons-lang-2.6.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-exec-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-service-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-jdbc-1.2.1000.2.4.0.0-169-standalone.jar:/usr/hdp/2.4.0.0-169/hive/lib/paranamer-2.3.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-jdbc-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/ant-1.9.1.jar:/usr/hdp/2.4.0.0-169/hive/lib/jsr305-3.0.0.jar:/usr/hdp/2.4.0.0-169/hive/lib/hive-hbase-handler-1.2.1000.2.4.0.0-169.jar:/usr/hdp/2.4.0.0-169/hive/lib/guava-14.0.1.jar:/usr/hdp/2.4.0.0-169/hive-hcatalog/share/hcatalog/hive-hcatalog-core-1.2.1000.2.4.0.0-169.jar:/root/apache-kylin-1.5.2.1/bin/..//lib/kylin-job-1.5.2.1.jar:/root/apache-kylin-1.5.2.1/bin/..//lib/kylin-coprocessor-1.5.2.1.jar:/root/apache-kylin-1.5.2.1/bin/..//lib/kylin-jdbc-1.5.2.1.jar:/root/apache-kylin-1.5.2.1/bin/..//ext/*:
2016-08-15 09:45:42,595 INFO  [main ZooKeeper:100]: Client environment:java.library.path=:/usr/hdp/2.4.0.0-169/hadoop/lib/native/Linux-amd64-64:/usr/hdp/2.4.0.0-169/hadoop/lib/native
2016-08-15 09:45:42,595 INFO  [main ZooKeeper:100]: Client environment:java.io.tmpdir=/tmp
2016-08-15 09:45:42,596 INFO  [main ZooKeeper:100]: Client environment:java.compiler=<NA>
2016-08-15 09:45:42,609 INFO  [main ZooKeeper:100]: Client environment:os.name=Linux
2016-08-15 09:45:42,609 INFO  [main ZooKeeper:100]: Client environment:os.arch=amd64
2016-08-15 09:45:42,609 INFO  [main ZooKeeper:100]: Client environment:os.version=2.6.32-573.18.1.el6.x86_64
2016-08-15 09:45:42,609 INFO  [main ZooKeeper:100]: Client environment:user.name=root
2016-08-15 09:45:42,610 INFO  [main ZooKeeper:100]: Client environment:user.home=/root
2016-08-15 09:45:42,610 INFO  [main ZooKeeper:100]: Client environment:user.dir=/root
2016-08-15 09:45:42,611 INFO  [main ZooKeeper:438]: Initiating client connection, connectString=sandbox.hortonworks.com:2181 sessionTimeout=60000 watcher=hconnection-0x720f19770x0, quorum=sandbox.hortonworks.com:2181, baseZNode=/hbase-unsecure
2016-08-15 09:45:42,658 INFO  [main-SendThread(sandbox.hortonworks.com:2181) ClientCnxn:1019]: Opening socket connection to server sandbox.hortonworks.com/192.168.239.132:2181. Will not attempt to authenticate using SASL (unknown error)
2016-08-15 09:45:42,671 INFO  [main-SendThread(sandbox.hortonworks.com:2181) ClientCnxn:864]: Socket connection established to sandbox.hortonworks.com/192.168.239.132:2181, initiating session
2016-08-15 09:45:42,687 INFO  [main-SendThread(sandbox.hortonworks.com:2181) ClientCnxn:1279]: Session establishment complete on server sandbox.hortonworks.com/192.168.239.132:2181, sessionid = 0x1568ce85621001c, negotiated timeout = 40000
2016-08-15 09:45:45,063 DEBUG [main HBaseConnection:188]: HTable 'kylin_metadata' already exists
2016-08-15 09:45:45,175 DEBUG [main CubeManager:817]: Loading Cube from folder kylin_metadata(key='/cube')@kylin_metadata@hbase
2016-08-15 09:45:45,604 INFO  [main CubeDescManager:91]: Initializing CubeDescManager with config kylin_metadata@hbase
2016-08-15 09:45:45,605 INFO  [main CubeDescManager:197]: Reloading Cube Metadata from folder kylin_metadata(key='/cube_desc')@kylin_metadata@hbase
2016-08-15 09:45:45,760 DEBUG [main MetadataManager:311]: Reloading SourceTable from folder kylin_metadata(key='/table')@kylin_metadata@hbase
2016-08-15 09:45:46,097 DEBUG [main MetadataManager:320]: Loaded 17 SourceTable(s)
2016-08-15 09:45:46,098 DEBUG [main MetadataManager:252]: Reloading SourceTable exd info from folder kylin_metadata(key='/table_exd')@kylin_metadata@hbase
2016-08-15 09:45:46,332 DEBUG [main MetadataManager:261]: Loaded 14 SourceTable EXD(s)
2016-08-15 09:45:46,332 DEBUG [main MetadataManager:427]: Reloading DataModel from folder kylin_metadata(key='/model_desc')@kylin_metadata@hbase
2016-08-15 09:45:46,497 DEBUG [main MetadataManager:441]: Loaded 6 DataModel(s)
2016-08-15 09:45:46,497 DEBUG [main MetadataManager:297]: Reloading ExternalFilter from folder kylin_metadata(key='/ext_filter')@kylin_metadata@hbase
2016-08-15 09:45:46,539 DEBUG [main MetadataManager:306]: Loaded 0 SourceTable(s)
2016-08-15 09:45:46,603 DEBUG [main CubeDescManager:222]: Loaded 6 Cube(s)
2016-08-15 09:45:46,608 DEBUG [main CubeManager:852]: Reloaded new cube: Product_Cube with reference beingCUBE[name=Product_Cube] having 0 segments:
2016-08-15 09:45:46,612 DEBUG [main CubeManager:852]: Reloaded new cube: Product_Cube_1 with reference beingCUBE[name=Product_Cube_1] having 0 segments:
2016-08-15 09:45:46,626 DEBUG [main CubeManager:852]: Reloaded new cube: Product_Cube_2 with reference beingCUBE[name=Product_Cube_2] having 1 segments:KYLIN_OOYQPKPUSV
2016-08-15 09:45:46,635 DEBUG [main CubeManager:852]: Reloaded new cube: Streaming_Cube with reference beingCUBE[name=Streaming_Cube] having 17 segments:KYLIN_O71JLBZAOY,KYLIN_RYLCSKWFA6,KYLIN_QI5RHA2QG8,KYLIN_6KDY71AMVZ,KYLIN_RQBYOKVTHM,KYLIN_J5P5V4L48C,KYLIN_TXZXP1VV8E,KYLIN_V6253723CB,KYLIN_SS098AG7K8,KYLIN_KZIS9HDWC6,KYLIN_LCYIKZ5ADM,KYLIN_6I0AODXTI4,KYLIN_462LVA085U,KYLIN_LOOYD7D3MW,KYLIN_AV1FSW1TI1,KYLIN_N3F0URAEYE,KYLIN_F3G3LU57KA
2016-08-15 09:45:46,640 DEBUG [main CubeManager:852]: Reloaded new cube: Test_Cube with reference beingCUBE[name=Test_Cube] having 1 segments:KYLIN_KJLIL0DRNL
2016-08-15 09:45:46,650 DEBUG [main CubeManager:852]: Reloaded new cube: kylin_sales_cube with reference beingCUBE[name=kylin_sales_cube] having 0 segments:
2016-08-15 09:45:46,650 DEBUG [main CubeManager:823]: Loaded 6 Cube(s)
2016-08-15 09:45:46,656 INFO  [main StreamingManager:218]: Reloading Streaming Metadata from folder kylin_metadata(key='/streaming')@kylin_metadata@hbase
2016-08-15 09:45:46,827 DEBUG [main StreamingManager:243]: Loaded 2 StreamingConfig(s)
2016-08-15 09:45:46,827 INFO  [main KafkaStreamingInput:86]: prepare to get streaming batch, name:DEFAULT.STREAMING_SALES_TABLE, id:-1, startTime:1471254300000, endTime:1471254600000
2016-08-15 09:45:46,851 INFO  [main KafkaConfigManager:204]: Reloading Kafka Metadata from folder kylin_metadata(key='/kafka')@kylin_metadata@hbase
2016-08-15 09:45:47,117 DEBUG [main KafkaConfigManager:229]: Loaded 2 KafkaConfig(s)
2016-08-15 09:45:47,133 INFO  [main TimedJsonStreamParser:95]: TimedJsonStreamParser with formatTs false tsColName order_time
2016-08-15 09:45:48,674 INFO  [pool-4-thread-1 KafkaUtils:105]: topic: kylin_demo, partitionId: 0, try to find closest offset with timestamp: 1471254000000 between offset {0, 10827}
2016-08-15 09:45:48,827 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 0 is: 1470908565679
2016-08-15 09:45:48,846 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10827 is: 1471254234068
2016-08-15 09:45:48,870 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 5413 is: 1470974757518
2016-08-15 09:45:48,881 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 5414 is: 1470974759521
2016-08-15 09:45:48,889 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 8120 is: 1471230599558
2016-08-15 09:45:48,898 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 8121 is: 1471230601562
2016-08-15 09:45:48,910 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 9474 is: 1471236132170
2016-08-15 09:45:48,931 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 9475 is: 1471236134172
2016-08-15 09:45:48,943 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10151 is: 1471237488268
2016-08-15 09:45:48,968 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10152 is: 1471237490271
2016-08-15 09:45:48,973 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10489 is: 1471238165979
2016-08-15 09:45:48,985 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10490 is: 1471238167982
2016-08-15 09:45:48,992 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10658 is: 1471238504958
2016-08-15 09:45:49,002 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10659 is: 1471238506962
2016-08-15 09:45:49,012 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10743 is: 1471238675394
2016-08-15 09:45:49,017 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10744 is: 1471238677397
2016-08-15 09:45:49,032 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10785 is: 1471238759667
2016-08-15 09:45:49,057 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10786 is: 1471254151155
2016-08-15 09:45:49,062 DEBUG [pool-4-thread-1 KafkaUtils:166]: The timestamp of topic: kylin_demo, partitionId: 0, offset: 10806 is: 1471254191882
2016-08-15 09:45:49,062 INFO  [pool-4-thread-1 KafkaUtils:107]: topic: kylin_demo, partitionId: 0, found offset: 10786
2016-08-15 09:45:49,065 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10786 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:45:49,101 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 1
2016-08-15 09:45:49,102 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:45:49,107 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 2
2016-08-15 09:45:49,107 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:46:19,107 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:46:19,109 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 3
2016-08-15 09:46:19,109 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:46:49,109 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:46:49,111 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 4
2016-08-15 09:46:49,111 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:47:19,111 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:47:19,115 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 5
2016-08-15 09:47:19,115 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:47:49,116 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:47:49,117 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 6
2016-08-15 09:47:49,118 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:48:19,118 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:48:19,122 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 7
2016-08-15 09:48:19,122 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:48:49,122 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:48:49,126 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 8
2016-08-15 09:48:49,126 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:49:19,127 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:49:19,129 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 9
2016-08-15 09:49:19,130 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:49:49,131 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:49:49,132 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 10
2016-08-15 09:49:49,132 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:50:19,133 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:50:19,135 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 11
2016-08-15 09:50:19,135 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:50:49,136 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:50:49,138 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 12
2016-08-15 09:50:49,138 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:51:19,138 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:51:19,140 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 13
2016-08-15 09:51:19,140 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:51:49,141 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:51:49,142 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 14
2016-08-15 09:51:49,142 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:52:19,143 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:52:19,144 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 15
2016-08-15 09:52:19,145 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:52:49,145 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:52:49,146 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 16
2016-08-15 09:52:49,147 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:53:19,147 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:53:19,149 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 17
2016-08-15 09:53:19,149 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:53:49,149 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:53:49,151 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 18
2016-08-15 09:53:49,151 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:54:19,152 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:54:19,157 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 19
2016-08-15 09:54:19,158 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:54:49,159 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:54:49,161 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 20
2016-08-15 09:54:49,161 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:55:19,162 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:55:19,165 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 21
2016-08-15 09:55:19,165 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:55:49,166 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:55:49,171 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 22
2016-08-15 09:55:49,171 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:56:19,172 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:56:19,173 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 23
2016-08-15 09:56:19,173 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:56:49,174 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:56:49,176 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 24
2016-08-15 09:56:49,176 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:57:19,176 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:57:19,178 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 25
2016-08-15 09:57:19,178 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:57:49,179 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:57:49,180 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 26
2016-08-15 09:57:49,180 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:58:19,181 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:58:19,182 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 27
2016-08-15 09:58:19,182 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:58:49,183 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:58:49,184 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 28
2016-08-15 09:58:49,184 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:59:19,184 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:59:19,186 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 29
2016-08-15 09:59:19,186 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 09:59:49,187 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 09:59:49,188 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 30
2016-08-15 09:59:49,188 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:00:19,188 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:00:19,190 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 31
2016-08-15 10:00:19,190 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:00:49,191 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:00:49,197 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 32
2016-08-15 10:00:49,197 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:01:19,198 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:01:19,199 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 33
2016-08-15 10:01:19,200 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:01:49,200 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:01:49,202 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 34
2016-08-15 10:01:49,202 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:02:19,203 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:02:19,204 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 35
2016-08-15 10:02:19,204 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:02:49,205 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:02:49,207 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 36
2016-08-15 10:02:49,207 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:03:19,207 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:03:19,208 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 37
2016-08-15 10:03:19,208 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:03:49,209 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:03:49,210 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 38
2016-08-15 10:03:49,210 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:04:19,211 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:04:19,212 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 39
2016-08-15 10:04:19,212 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:04:49,213 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:04:49,214 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 40
2016-08-15 10:04:49,214 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:05:19,215 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:05:19,217 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 41
2016-08-15 10:05:19,217 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:05:49,218 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:05:49,221 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 42
2016-08-15 10:05:49,221 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:06:19,222 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:06:19,224 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 43
2016-08-15 10:06:19,224 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:06:49,225 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:06:49,227 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 44
2016-08-15 10:06:49,227 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:07:19,228 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:07:19,242 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 45
2016-08-15 10:07:19,242 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:07:49,243 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:07:49,244 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 46
2016-08-15 10:07:49,244 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:08:19,245 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:08:19,246 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 47
2016-08-15 10:08:19,246 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:08:49,247 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:08:49,249 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 48
2016-08-15 10:08:49,249 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:09:19,249 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:09:19,251 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 49
2016-08-15 10:09:19,252 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:09:49,252 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:09:49,254 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 50
2016-08-15 10:09:49,254 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:10:19,254 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:10:19,256 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 51
2016-08-15 10:10:19,256 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:10:49,256 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:10:49,260 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 52
2016-08-15 10:10:49,260 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:11:19,261 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:11:19,262 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 53
2016-08-15 10:11:19,262 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:11:49,263 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:11:49,264 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 54
2016-08-15 10:11:49,264 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:12:19,265 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:12:19,266 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 55
2016-08-15 10:12:19,266 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:12:49,266 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:12:49,268 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 56
2016-08-15 10:12:49,268 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:13:19,269 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:13:19,270 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 57
2016-08-15 10:13:19,270 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:13:49,271 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:13:49,273 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 58
2016-08-15 10:13:49,273 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:14:19,274 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:14:19,276 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 59
2016-08-15 10:14:19,276 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:14:49,277 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:14:49,280 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 60
2016-08-15 10:14:49,280 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:15:19,281 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:15:19,283 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 61
2016-08-15 10:15:19,283 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:15:49,283 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:15:49,285 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 62
2016-08-15 10:15:49,285 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:16:19,286 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:16:19,288 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 63
2016-08-15 10:16:19,288 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:16:49,288 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:16:49,290 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 64
2016-08-15 10:16:49,290 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:17:19,290 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:17:19,292 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 65
2016-08-15 10:17:19,292 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:17:49,292 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:17:49,294 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 66
2016-08-15 10:17:49,294 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:18:19,294 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:18:19,296 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 67
2016-08-15 10:18:19,296 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:18:49,297 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:18:49,298 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 68
2016-08-15 10:18:49,298 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:19:19,299 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:19:19,300 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 69
2016-08-15 10:19:19,300 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:19:49,301 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:19:49,303 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 70
2016-08-15 10:19:49,303 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:20:19,304 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:20:19,320 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 71
2016-08-15 10:20:19,320 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:20:49,321 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:20:49,324 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 72
2016-08-15 10:20:49,324 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:21:19,324 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:21:19,326 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 73
2016-08-15 10:21:19,326 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:21:49,326 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:21:49,327 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 74
2016-08-15 10:21:49,328 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:22:19,328 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:22:19,330 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 75
2016-08-15 10:22:19,330 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:22:49,330 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:22:49,332 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 76
2016-08-15 10:22:49,332 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:23:19,332 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:23:19,334 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 77
2016-08-15 10:23:19,334 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:23:49,334 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:23:49,336 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 78
2016-08-15 10:23:49,336 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:24:19,336 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:24:19,338 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 79
2016-08-15 10:24:19,338 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:24:49,339 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:24:49,341 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 80
2016-08-15 10:24:49,341 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:25:19,341 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:25:19,343 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 81
2016-08-15 10:25:19,343 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:25:49,344 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:25:49,346 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 82
2016-08-15 10:25:49,346 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:26:19,346 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:26:19,348 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 83
2016-08-15 10:26:19,348 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:26:49,349 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:26:49,351 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 84
2016-08-15 10:26:49,351 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:27:19,352 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:27:19,353 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 85
2016-08-15 10:27:19,353 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:27:49,353 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:27:49,355 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 86
2016-08-15 10:27:49,355 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:28:19,356 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:28:19,357 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 87
2016-08-15 10:28:19,357 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:28:49,366 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:28:49,379 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 88
2016-08-15 10:28:49,379 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:29:19,380 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:29:19,382 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 89
2016-08-15 10:29:19,383 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:29:49,384 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:29:49,395 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 90
2016-08-15 10:29:49,395 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:30:19,396 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:30:19,399 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 91
2016-08-15 10:30:19,400 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:30:49,400 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:30:49,401 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 92
2016-08-15 10:30:49,401 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:31:19,404 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:31:19,414 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 93
2016-08-15 10:31:19,414 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:31:49,415 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:31:49,416 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 94
2016-08-15 10:31:49,416 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:32:19,417 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:32:19,418 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 95
2016-08-15 10:32:19,418 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:32:49,419 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:32:49,420 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 96
2016-08-15 10:32:49,420 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:33:19,421 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:33:19,422 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 97
2016-08-15 10:33:19,422 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:33:49,423 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:33:49,424 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 98
2016-08-15 10:33:49,424 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:34:19,425 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:34:19,430 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 99
2016-08-15 10:34:19,430 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:34:49,430 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:34:49,432 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 100
2016-08-15 10:34:49,432 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:35:19,433 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:35:19,435 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 101
2016-08-15 10:35:19,435 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:35:49,436 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:35:49,437 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 102
2016-08-15 10:35:49,437 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:36:19,438 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:36:19,439 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 103
2016-08-15 10:36:19,439 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:36:49,440 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:36:49,442 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 104
2016-08-15 10:36:49,442 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:37:19,442 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:37:19,444 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 105
2016-08-15 10:37:19,444 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:37:49,444 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:37:49,446 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 106
2016-08-15 10:37:49,446 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:38:19,447 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:38:19,448 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 107
2016-08-15 10:38:19,448 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:38:49,449 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:38:49,450 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 108
2016-08-15 10:38:49,450 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:39:19,451 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:39:19,452 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 109
2016-08-15 10:39:19,452 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:39:49,452 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:39:49,455 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 110
2016-08-15 10:39:49,455 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:40:19,456 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:40:19,457 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 111
2016-08-15 10:40:19,457 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:40:49,458 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:40:49,459 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 112
2016-08-15 10:40:49,459 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:41:19,460 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:41:19,461 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 113
2016-08-15 10:41:19,461 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:41:49,462 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:41:49,463 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 114
2016-08-15 10:41:49,464 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:42:19,464 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:42:19,466 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 115
2016-08-15 10:42:19,466 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:42:49,467 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:42:49,468 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 116
2016-08-15 10:42:49,468 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:43:19,468 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:43:19,470 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 117
2016-08-15 10:43:19,470 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:43:49,470 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:43:49,472 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 118
2016-08-15 10:43:49,472 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:44:19,472 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:44:19,474 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 119
2016-08-15 10:44:19,475 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:44:49,475 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:44:49,477 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 120
2016-08-15 10:44:49,477 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:45:19,477 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:45:19,479 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 121
2016-08-15 10:45:19,480 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:45:49,480 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:45:49,509 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 122
2016-08-15 10:45:49,509 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:46:19,510 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:46:19,512 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 123
2016-08-15 10:46:19,512 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:46:49,513 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:46:49,515 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 124
2016-08-15 10:46:49,515 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:47:19,515 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:47:19,516 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 125
2016-08-15 10:47:19,517 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:47:49,517 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:47:49,518 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 126
2016-08-15 10:47:49,519 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:48:19,519 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:48:19,520 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 127
2016-08-15 10:48:19,521 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:48:49,521 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:48:49,523 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 128
2016-08-15 10:48:49,524 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:49:19,524 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:49:19,526 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 129
2016-08-15 10:49:19,526 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:49:49,527 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:49:49,528 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 130
2016-08-15 10:49:49,528 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:50:19,529 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:50:19,530 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 131
2016-08-15 10:50:19,530 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:50:49,531 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:50:49,534 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 132
2016-08-15 10:50:49,535 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:51:19,535 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:51:19,538 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 133
2016-08-15 10:51:19,538 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:51:49,539 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:51:49,542 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 134
2016-08-15 10:51:49,542 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:52:19,542 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:52:19,544 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 135
2016-08-15 10:52:19,544 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:52:49,544 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:52:49,545 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 136
2016-08-15 10:52:49,545 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:53:19,546 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:53:19,547 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 137
2016-08-15 10:53:19,547 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:53:49,548 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:53:49,550 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 138
2016-08-15 10:53:49,550 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:54:19,550 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:54:19,554 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 139
2016-08-15 10:54:19,554 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:54:49,556 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:54:49,559 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 140
2016-08-15 10:54:49,559 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:55:19,559 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:55:19,561 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 141
2016-08-15 10:55:19,561 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:55:49,561 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:55:49,564 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 142
2016-08-15 10:55:49,564 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:56:19,564 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:56:19,566 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 143
2016-08-15 10:56:19,566 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:56:49,566 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:56:49,568 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 144
2016-08-15 10:56:49,568 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:57:19,569 INFO  [pool-4-thread-1 KafkaStreamingInput:181]: fetching topic kylin_demo partition id 0 offset 10828 leader id:1001,host:sandbox.hortonworks.com,port:6667
2016-08-15 10:57:19,570 INFO  [pool-4-thread-1 KafkaStreamingInput:207]: Number of messages consumed: 42 offset is: 10828 total fetch round: 145
2016-08-15 10:57:19,571 INFO  [pool-4-thread-1 KafkaStreamingInput:212]: no message consumed this round, wait 30s
2016-08-15 10:57:26,049 INFO  [Thread-0 ConnectionManager$HConnectionImplementation:1683]: Closing zookeeper sessionid=0x1568ce85621001c