flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Todd Lisonbee (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3716) Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass
Date Thu, 07 Apr 2016 20:41:25 GMT
Todd Lisonbee created FLINK-3716:
------------------------------------

             Summary: Kafka08ITCase.testFailOnNoBroker() timing out before it has a chance to pass
                 Key: FLINK-3716
                 URL: https://issues.apache.org/jira/browse/FLINK-3716
             Project: Flink
          Issue Type: Bug
            Reporter: Todd Lisonbee


This is on the latest master 4/7/2016 with `mvn clean verify`.  

Test also reliably fails running it directly from IntelliJ.

Test has a 60 second timeout but it seems to need much more time to run (my workstation has server class Xeon).

-------------------

/usr/lib/jvm/java-1.8.0-openjdk.x86_64/bin/java -ea -DforkNumber=01 -Xms256m -Xmx800m -Dlog4j.configuration=log4j-test.properties -Dmvn.forkNumber=1 -XX:-UseGCOverheadLimit -Didea.launcher.port=7546 -Didea.launcher.bin.path=/home/iauser/bin/idea-IU-141.1532.4/bin -Dfile.encoding=UTF-8 -classpath /home/iauser/bin/idea-IU-141.1532.4/lib/idea_rt.jar:/home/iauser/bin/idea-IU-141.1532.4/plugins/junit/lib/junit-rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/resources.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jsse.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jce.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/charsets.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/management-agent.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/cldrdata.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/test-classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/classes:/home/iauser/.m2/repository/com/101tec/zkclient/0.7/zkclient-0.7.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/test-classes:/home/iauser/flink-src/flink-streaming-java/target/classes:/home/iauser/flink-src/flink-core/target/classes:/home/iauser/flink-src/flink-annotations/target/classes:/home/iauser/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/home/iauser/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/home/iauser/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/home/iauser/.m2/repository/org/apache/avro/avro/1.7.6/avro-1.7.6.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/home/iauser/.m2/repository/com/thoughtworks/paranamer/paranamer/2.3/paranamer-2.3.jar:/home/iauser/.m2/repository/org/apache/flink/flink-shaded-hadoop2/1.1-SNAPSHOT/flink-shaded-hadoop2-1.1-20160311.122535-32.jar:/home/iauser/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/home/iauser/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/home/iauser/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/home/iauser/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/home/iauser/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/home/iauser/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/home/iauser/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/home/iauser/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/home/iauser/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/home/iauser/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/home/iauser/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/home/iauser/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/home/iauser/.m2/repository/commons-configuration/commons-configuration/1.7/commons-configuration-1.7.jar:/home/iauser/.m2/repository/commons-digester/commons-digester/1.8.1/commons-digester-1.8.1.jar:/home/iauser/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/home/iauser/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/home/iauser/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/home/iauser/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/home/iauser/.m2/repository/commons-beanutils/commons-beanutils-bean-collections/1.8.3/commons-beanutils-bean-collections-1.8.3.jar:/home/iauser/.m2/repository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/home/iauser/.m2/repository/javax/xml/bind/jaxb-api/2.2.2/jaxb-api-2.2.2.jar:/home/iauser/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/home/iauser/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/home/iauser/.m2/repository/com/google/inject/guice/3.0/guice-3.0.jar:/home/iauser/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/home/iauser/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/home/iauser/flink-src/flink-runtime/target/classes:/home/iauser/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/home/iauser/.m2/repository/io/netty/netty-all/4.0.27.Final/netty-all-4.0.27.Final.jar:/home/iauser/.m2/repository/org/ow2/asm/asm-all/5.0.4/asm-all-5.0.4.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-actor_2.10/2.3.7/akka-actor_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/typesafe/config/1.2.1/config-1.2.1.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-remote_2.10/2.3.7/akka-remote_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/home/iauser/.m2/repository/org/uncommons/maths/uncommons-maths/1.2.2a/uncommons-maths-1.2.2a.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-slf4j_2.10/2.3.7/akka-slf4j_2.10-2.3.7.jar:/home/iauser/.m2/repository/org/clapper/grizzled-slf4j_2.10/1.0.2/grizzled-slf4j_2.10-1.0.2.jar:/home/iauser/.m2/repository/com/github/scopt/scopt_2.10/3.2.0/scopt_2.10-3.2.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-core/3.1.0/metrics-core-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.1.0/metrics-jvm-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-json/3.1.0/metrics-json-3.1.0.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.4.2/jackson-databind-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.4.2/jackson-annotations-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.4.2/jackson-core-2.4.2.jar:/home/iauser/.m2/repository/com/twitter/chill_2.10/0.7.4/chill_2.10-0.7.4.jar:/home/iauser/.m2/repository/com/twitter/chill-java/0.7.4/chill-java-0.7.4.jar:/home/iauser/flink-src/flink-clients/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/home/iauser/.m2/repository/org/apache/sling/org.apache.sling.commons.json/2.0.6/org.apache.sling.commons.json-2.0.6.jar:/home/iauser/.m2/repository/com/google/guava/guava/18.0/guava-18.0.jar:/home/iauser/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka_2.10/0.8.2.2/kafka_2.10-0.8.2.2.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar:/home/iauser/.m2/repository/net/jpountz/lz4/lz4/1.2.0/lz4-1.2.0.jar:/home/iauser/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/home/iauser/.m2/repository/org/scala-lang/scala-library/2.10.4/scala-library-2.10.4.jar:/home/iauser/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6.jar:/home/iauser/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/home/iauser/.m2/repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/home/iauser/.m2/repository/org/apache/curator/curator-test/2.8.0/curator-test-2.8.0.jar:/home/iauser/.m2/repository/org/javassist/javassist/3.18.2-GA/javassist-3.18.2-GA.jar:/home/iauser/flink-src/flink-shaded-curator/flink-shaded-curator-recipes/target/classes:/home/iauser/.m2/repository/org/apache/curator/curator-recipes/2.8.0/curator-recipes-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-framework/2.8.0/curator-framework-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-client/2.8.0/curator-client-2.8.0.jar:/home/iauser/flink-src/flink-test-utils/target/classes:/home/iauser/flink-src/flink-optimizer/target/classes:/home/iauser/flink-src/flink-core/target/test-classes:/home/iauser/flink-src/flink-runtime/target/test-classes:/home/iauser/flink-src/flink-java/target/classes:/home/iauser/.m2/repository/org/scalatest/scalatest_2.10/2.2.2/scalatest_2.10-2.2.2.jar:/home/iauser/.m2/repository/org/scala-lang/scala-reflect/2.10.4/scala-reflect-2.10.4.jar:/home/iauser/flink-src/flink-tests/target/test-classes:/home/iauser/flink-src/tools/force-shading/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-api/1.7.7/slf4j-api-1.7.7.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar:/home/iauser/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/home/iauser/.m2/repository/junit/junit/4.11/junit-4.11.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/home/iauser/.m2/repository/org/mockito/mockito-all/1.9.5/mockito-all-1.9.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4/1.5.5/powermock-module-junit4-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4-common/1.5.5/powermock-module-junit4-common-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-core/1.5.5/powermock-core-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-reflect/1.5.5/powermock-reflect-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-mockito/1.5.5/powermock-api-mockito-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-support/1.5.5/powermock-api-support-1.5.5.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar com.intellij.rt.execution.application.AppMain com.intellij.rt.execution.junit.JUnitStarter -ideVersion5 org.apache.flink.streaming.connectors.kafka.Kafka08ITCase,testFailOnNoBroker
0    [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  - -------------------------------------------------------------------------
2    [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  -     Starting KafkaTestBase 
3    [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  - -------------------------------------------------------------------------
11   [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  - Starting KafkaTestBase.prepare() for Kafka 0.8
30   [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - Starting Zookeeper
195  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServerMain  - Starting server
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:host.name=gao-wse.jf.intel.com
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.version=1.8.0_51
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.vendor=Oracle Corporation
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.51-3.b16.el6_7.x86_64/jre
203  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.class.path=/home/iauser/bin/idea-IU-141.1532.4/lib/idea_rt.jar:/home/iauser/bin/idea-IU-141.1532.4/plugins/junit/lib/junit-rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/resources.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jsse.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jce.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/charsets.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/management-agent.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/cldrdata.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/test-classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/classes:/home/iauser/.m2/repository/com/101tec/zkclient/0.7/zkclient-0.7.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/test-classes:/home/iauser/flink-src/flink-streaming-java/target/classes:/home/iauser/flink-src/flink-core/target/classes:/home/iauser/flink-src/flink-annotations/target/classes:/home/iauser/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/home/iauser/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/home/iauser/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/home/iauser/.m2/repository/org/apache/avro/avro/1.7.6/avro-1.7.6.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/home/iauser/.m2/repository/com/thoughtworks/paranamer/paranamer/2.3/paranamer-2.3.jar:/home/iauser/.m2/repository/org/apache/flink/flink-shaded-hadoop2/1.1-SNAPSHOT/flink-shaded-hadoop2-1.1-20160311.122535-32.jar:/home/iauser/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/home/iauser/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/home/iauser/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/home/iauser/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/home/iauser/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/home/iauser/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/home/iauser/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/home/iauser/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/home/iauser/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/home/iauser/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/home/iauser/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/home/iauser/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/home/iauser/.m2/repository/commons-configuration/commons-configuration/1.7/commons-configuration-1.7.jar:/home/iauser/.m2/repository/commons-digester/commons-digester/1.8.1/commons-digester-1.8.1.jar:/home/iauser/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/home/iauser/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/home/iauser/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/home/iauser/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/home/iauser/.m2/repository/commons-beanutils/commons-beanutils-bean-collections/1.8.3/commons-beanutils-bean-collections-1.8.3.jar:/home/iauser/.m2/repository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/home/iauser/.m2/repository/javax/xml/bind/jaxb-api/2.2.2/jaxb-api-2.2.2.jar:/home/iauser/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/home/iauser/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/home/iauser/.m2/repository/com/google/inject/guice/3.0/guice-3.0.jar:/home/iauser/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/home/iauser/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/home/iauser/flink-src/flink-runtime/target/classes:/home/iauser/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/home/iauser/.m2/repository/io/netty/netty-all/4.0.27.Final/netty-all-4.0.27.Final.jar:/home/iauser/.m2/repository/org/ow2/asm/asm-all/5.0.4/asm-all-5.0.4.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-actor_2.10/2.3.7/akka-actor_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/typesafe/config/1.2.1/config-1.2.1.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-remote_2.10/2.3.7/akka-remote_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/home/iauser/.m2/repository/org/uncommons/maths/uncommons-maths/1.2.2a/uncommons-maths-1.2.2a.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-slf4j_2.10/2.3.7/akka-slf4j_2.10-2.3.7.jar:/home/iauser/.m2/repository/org/clapper/grizzled-slf4j_2.10/1.0.2/grizzled-slf4j_2.10-1.0.2.jar:/home/iauser/.m2/repository/com/github/scopt/scopt_2.10/3.2.0/scopt_2.10-3.2.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-core/3.1.0/metrics-core-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.1.0/metrics-jvm-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-json/3.1.0/metrics-json-3.1.0.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.4.2/jackson-databind-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.4.2/jackson-annotations-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.4.2/jackson-core-2.4.2.jar:/home/iauser/.m2/repository/com/twitter/chill_2.10/0.7.4/chill_2.10-0.7.4.jar:/home/iauser/.m2/repository/com/twitter/chill-java/0.7.4/chill-java-0.7.4.jar:/home/iauser/flink-src/flink-clients/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/home/iauser/.m2/repository/org/apache/sling/org.apache.sling.commons.json/2.0.6/org.apache.sling.commons.json-2.0.6.jar:/home/iauser/.m2/repository/com/google/guava/guava/18.0/guava-18.0.jar:/home/iauser/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka_2.10/0.8.2.2/kafka_2.10-0.8.2.2.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar:/home/iauser/.m2/repository/net/jpountz/lz4/lz4/1.2.0/lz4-1.2.0.jar:/home/iauser/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/home/iauser/.m2/repository/org/scala-lang/scala-library/2.10.4/scala-library-2.10.4.jar:/home/iauser/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6.jar:/home/iauser/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/home/iauser/.m2/repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/home/iauser/.m2/repository/org/apache/curator/curator-test/2.8.0/curator-test-2.8.0.jar:/home/iauser/.m2/repository/org/javassist/javassist/3.18.2-GA/javassist-3.18.2-GA.jar:/home/iauser/flink-src/flink-shaded-curator/flink-shaded-curator-recipes/target/classes:/home/iauser/.m2/repository/org/apache/curator/curator-recipes/2.8.0/curator-recipes-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-framework/2.8.0/curator-framework-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-client/2.8.0/curator-client-2.8.0.jar:/home/iauser/flink-src/flink-test-utils/target/classes:/home/iauser/flink-src/flink-optimizer/target/classes:/home/iauser/flink-src/flink-core/target/test-classes:/home/iauser/flink-src/flink-runtime/target/test-classes:/home/iauser/flink-src/flink-java/target/classes:/home/iauser/.m2/repository/org/scalatest/scalatest_2.10/2.2.2/scalatest_2.10-2.2.2.jar:/home/iauser/.m2/repository/org/scala-lang/scala-reflect/2.10.4/scala-reflect-2.10.4.jar:/home/iauser/flink-src/flink-tests/target/test-classes:/home/iauser/flink-src/tools/force-shading/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-api/1.7.7/slf4j-api-1.7.7.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar:/home/iauser/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/home/iauser/.m2/repository/junit/junit/4.11/junit-4.11.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/home/iauser/.m2/repository/org/mockito/mockito-all/1.9.5/mockito-all-1.9.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4/1.5.5/powermock-module-junit4-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4-common/1.5.5/powermock-module-junit4-common-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-core/1.5.5/powermock-core-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-reflect/1.5.5/powermock-reflect-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-mockito/1.5.5/powermock-api-mockito-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-support/1.5.5/powermock-api-support-1.5.5.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar
216  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.library.path=/home/iauser/bin/idea-IU-141.1532.4/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
216  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.io.tmpdir=/tmp
216  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:java.compiler=<NA>
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:os.name=Linux
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:os.arch=amd64
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:os.version=2.6.32-358.el6.x86_64
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:user.name=iauser
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:user.home=/home/iauser
217  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Server environment:user.dir=/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8
223  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - tickTime set to 3000
223  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - minSessionTimeout set to -1
223  [Thread-0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - maxSessionTimeout set to -1
235  [Thread-0] INFO  org.apache.zookeeper.server.NIOServerCnxnFactory  - binding to port 0.0.0.0/0.0.0.0:39234
1261 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - Starting KafkaServer
1266 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - Starting broker with id 0
1395 [main] INFO  kafka.utils.VerifiableProperties  - Verifying properties
1425 [main] INFO  kafka.utils.VerifiableProperties  - Property advertised.host.name is overridden to localhost
1425 [main] INFO  kafka.utils.VerifiableProperties  - Property broker.id is overridden to 0
1425 [main] INFO  kafka.utils.VerifiableProperties  - Property log.dir is overridden to /tmp/kafkaITcase-kafka-dirb3ceca9d-080c-4be6-80c5-57c989b65e7e/server-0
1426 [main] INFO  kafka.utils.VerifiableProperties  - Property message.max.bytes is overridden to 52428800
1426 [main] INFO  kafka.utils.VerifiableProperties  - Property port is overridden to 41274
1426 [main] INFO  kafka.utils.VerifiableProperties  - Property replica.fetch.max.bytes is overridden to 52428800
1426 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connect is overridden to 127.0.0.1:39234
1426 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connection.timeout.ms is overridden to 30000
1427 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.session.timeout.ms is overridden to 30000
1450 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 0], starting
1453 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 0], Connecting to zookeeper on 127.0.0.1:39234
1460 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  org.I0Itec.zkclient.ZkEventThread  - Starting ZkClient event thread.
1464 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:zookeeper.version=3.4.6-1569965, built on 02/20/2014 09:09 GMT
1464 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:host.name=gao-wse.jf.intel.com
1464 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.version=1.8.0_51
1465 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.vendor=Oracle Corporation
1465 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.home=/usr/lib/jvm/java-1.8.0-openjdk-1.8.0.51-3.b16.el6_7.x86_64/jre
1465 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.class.path=/home/iauser/bin/idea-IU-141.1532.4/lib/idea_rt.jar:/home/iauser/bin/idea-IU-141.1532.4/plugins/junit/lib/junit-rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/resources.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jsse.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/jce.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/charsets.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/rt.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/management-agent.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunec.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunpkcs11.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/sunjce_provider.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/zipfs.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/localedata.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/nashorn.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/dnsns.jar:/usr/lib/jvm/java-1.8.0-openjdk.x86_64/jre/lib/ext/cldrdata.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/test-classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8/target/classes:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/classes:/home/iauser/.m2/repository/com/101tec/zkclient/0.7/zkclient-0.7.jar:/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-base/target/test-classes:/home/iauser/flink-src/flink-streaming-java/target/classes:/home/iauser/flink-src/flink-core/target/classes:/home/iauser/flink-src/flink-annotations/target/classes:/home/iauser/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/home/iauser/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/home/iauser/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/home/iauser/.m2/repository/org/apache/avro/avro/1.7.6/avro-1.7.6.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/home/iauser/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/home/iauser/.m2/repository/com/thoughtworks/paranamer/paranamer/2.3/paranamer-2.3.jar:/home/iauser/.m2/repository/org/apache/flink/flink-shaded-hadoop2/1.1-SNAPSHOT/flink-shaded-hadoop2-1.1-20160311.122535-32.jar:/home/iauser/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/home/iauser/.m2/repository/commons-codec/commons-codec/1.4/commons-codec-1.4.jar:/home/iauser/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/home/iauser/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/home/iauser/.m2/repository/commons-collections/commons-collections/3.2.1/commons-collections-3.2.1.jar:/home/iauser/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/home/iauser/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/home/iauser/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/home/iauser/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/home/iauser/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/home/iauser/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/home/iauser/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/home/iauser/.m2/repository/commons-configuration/commons-configuration/1.7/commons-configuration-1.7.jar:/home/iauser/.m2/repository/commons-digester/commons-digester/1.8.1/commons-digester-1.8.1.jar:/home/iauser/.m2/repository/org/xerial/snappy/snappy-java/1.0.5/snappy-java-1.0.5.jar:/home/iauser/.m2/repository/com/jcraft/jsch/0.1.42/jsch-0.1.42.jar:/home/iauser/.m2/repository/org/apache/commons/commons-compress/1.4.1/commons-compress-1.4.1.jar:/home/iauser/.m2/repository/org/tukaani/xz/1.0/xz-1.0.jar:/home/iauser/.m2/repository/commons-beanutils/commons-beanutils-bean-collections/1.8.3/commons-beanutils-bean-collections-1.8.3.jar:/home/iauser/.m2/repository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/home/iauser/.m2/repository/javax/xml/bind/jaxb-api/2.2.2/jaxb-api-2.2.2.jar:/home/iauser/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/home/iauser/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/home/iauser/.m2/repository/com/google/inject/guice/3.0/guice-3.0.jar:/home/iauser/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/home/iauser/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/home/iauser/flink-src/flink-runtime/target/classes:/home/iauser/.m2/repository/commons-cli/commons-cli/1.2/commons-cli-1.2.jar:/home/iauser/.m2/repository/io/netty/netty-all/4.0.27.Final/netty-all-4.0.27.Final.jar:/home/iauser/.m2/repository/org/ow2/asm/asm-all/5.0.4/asm-all-5.0.4.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-actor_2.10/2.3.7/akka-actor_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/typesafe/config/1.2.1/config-1.2.1.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-remote_2.10/2.3.7/akka-remote_2.10-2.3.7.jar:/home/iauser/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/home/iauser/.m2/repository/org/uncommons/maths/uncommons-maths/1.2.2a/uncommons-maths-1.2.2a.jar:/home/iauser/.m2/repository/com/typesafe/akka/akka-slf4j_2.10/2.3.7/akka-slf4j_2.10-2.3.7.jar:/home/iauser/.m2/repository/org/clapper/grizzled-slf4j_2.10/1.0.2/grizzled-slf4j_2.10-1.0.2.jar:/home/iauser/.m2/repository/com/github/scopt/scopt_2.10/3.2.0/scopt_2.10-3.2.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-core/3.1.0/metrics-core-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.1.0/metrics-jvm-3.1.0.jar:/home/iauser/.m2/repository/io/dropwizard/metrics/metrics-json/3.1.0/metrics-json-3.1.0.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.4.2/jackson-databind-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.4.2/jackson-annotations-2.4.2.jar:/home/iauser/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.4.2/jackson-core-2.4.2.jar:/home/iauser/.m2/repository/com/twitter/chill_2.10/0.7.4/chill_2.10-0.7.4.jar:/home/iauser/.m2/repository/com/twitter/chill-java/0.7.4/chill-java-0.7.4.jar:/home/iauser/flink-src/flink-clients/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/home/iauser/.m2/repository/org/apache/sling/org.apache.sling.commons.json/2.0.6/org.apache.sling.commons.json-2.0.6.jar:/home/iauser/.m2/repository/com/google/guava/guava/18.0/guava-18.0.jar:/home/iauser/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka_2.10/0.8.2.2/kafka_2.10-0.8.2.2.jar:/home/iauser/.m2/repository/org/apache/kafka/kafka-clients/0.8.2.2/kafka-clients-0.8.2.2.jar:/home/iauser/.m2/repository/net/jpountz/lz4/lz4/1.2.0/lz4-1.2.0.jar:/home/iauser/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/home/iauser/.m2/repository/org/scala-lang/scala-library/2.10.4/scala-library-2.10.4.jar:/home/iauser/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6.jar:/home/iauser/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/home/iauser/.m2/repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/home/iauser/.m2/repository/org/apache/curator/curator-test/2.8.0/curator-test-2.8.0.jar:/home/iauser/.m2/repository/org/javassist/javassist/3.18.2-GA/javassist-3.18.2-GA.jar:/home/iauser/flink-src/flink-shaded-curator/flink-shaded-curator-recipes/target/classes:/home/iauser/.m2/repository/org/apache/curator/curator-recipes/2.8.0/curator-recipes-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-framework/2.8.0/curator-framework-2.8.0.jar:/home/iauser/.m2/repository/org/apache/curator/curator-client/2.8.0/curator-client-2.8.0.jar:/home/iauser/flink-src/flink-test-utils/target/classes:/home/iauser/flink-src/flink-optimizer/target/classes:/home/iauser/flink-src/flink-core/target/test-classes:/home/iauser/flink-src/flink-runtime/target/test-classes:/home/iauser/flink-src/flink-java/target/classes:/home/iauser/.m2/repository/org/scalatest/scalatest_2.10/2.2.2/scalatest_2.10-2.2.2.jar:/home/iauser/.m2/repository/org/scala-lang/scala-reflect/2.10.4/scala-reflect-2.10.4.jar:/home/iauser/flink-src/flink-tests/target/test-classes:/home/iauser/flink-src/tools/force-shading/target/classes:/home/iauser/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-api/1.7.7/slf4j-api-1.7.7.jar:/home/iauser/.m2/repository/org/slf4j/slf4j-log4j12/1.7.7/slf4j-log4j12-1.7.7.jar:/home/iauser/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/home/iauser/.m2/repository/junit/junit/4.11/junit-4.11.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/home/iauser/.m2/repository/org/mockito/mockito-all/1.9.5/mockito-all-1.9.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4/1.5.5/powermock-module-junit4-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-module-junit4-common/1.5.5/powermock-module-junit4-common-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-core/1.5.5/powermock-core-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-reflect/1.5.5/powermock-reflect-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-mockito/1.5.5/powermock-api-mockito-1.5.5.jar:/home/iauser/.m2/repository/org/powermock/powermock-api-support/1.5.5/powermock-api-support-1.5.5.jar:/home/iauser/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar
1480 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.library.path=/home/iauser/bin/idea-IU-141.1532.4/bin::/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
1480 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.io.tmpdir=/tmp
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:java.compiler=<NA>
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:os.name=Linux
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:os.arch=amd64
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:os.version=2.6.32-358.el6.x86_64
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:user.name=iauser
1481 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:user.home=/home/iauser
1482 [main] INFO  org.apache.zookeeper.ZooKeeper  - Client environment:user.dir=/home/iauser/flink-src/flink-streaming-connectors/flink-connector-kafka-0.8
1483 [main] INFO  org.apache.zookeeper.ZooKeeper  - Initiating client connection, connectString=127.0.0.1:39234 sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@776aec5c
1494 [main] INFO  org.I0Itec.zkclient.ZkClient  - Waiting for keeper state SyncConnected
1498 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Opening socket connection to server 127.0.0.1/127.0.0.1:39234. Will not attempt to authenticate using SASL (unknown error)
1516 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Socket connection established to 127.0.0.1/127.0.0.1:39234, initiating session
1516 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.NIOServerCnxnFactory  - Accepted socket connection from /127.0.0.1:55714
1528 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Client attempting to establish new session at /127.0.0.1:55714
1533 [SyncThread:0] INFO  org.apache.zookeeper.server.persistence.FileTxnLog  - Creating new log file: log.1
1586 [SyncThread:0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Established session 0x153ef385acf0000 with negotiated timeout 30000 for client /127.0.0.1:55714
1586 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Session establishment complete on server 127.0.0.1/127.0.0.1:39234, sessionid = 0x153ef385acf0000, negotiated timeout = 30000
1590 [main-EventThread] INFO  org.I0Itec.zkclient.ZkClient  - zookeeper state changed (SyncConnected)
1633 [ProcessThread(sid:0 cport:-1):] INFO  org.apache.zookeeper.server.PrepRequestProcessor  - Got user-level KeeperException when processing sessionid:0x153ef385acf0000 type:create cxid:0x4 zxid:0x3 txntype:-1 reqpath:n/a Error Path:/brokers Error:KeeperErrorCode = NoNode for /brokers
1667 [ProcessThread(sid:0 cport:-1):] INFO  org.apache.zookeeper.server.PrepRequestProcessor  - Got user-level KeeperException when processing sessionid:0x153ef385acf0000 type:create cxid:0xa zxid:0x7 txntype:-1 reqpath:n/a Error Path:/config Error:KeeperErrorCode = NoNode for /config
1701 [ProcessThread(sid:0 cport:-1):] INFO  org.apache.zookeeper.server.PrepRequestProcessor  - Got user-level KeeperException when processing sessionid:0x153ef385acf0000 type:create cxid:0x10 zxid:0xb txntype:-1 reqpath:n/a Error Path:/admin Error:KeeperErrorCode = NoNode for /admin
1769 [main] INFO  kafka.log.LogManager  - Loading logs.
1776 [main] INFO  kafka.log.LogManager  - Logs loading complete.
1777 [main] INFO  kafka.log.LogManager  - Starting log cleanup with a period of 300000 ms.
1780 [main] INFO  kafka.log.LogManager  - Starting log flusher with a default period of 9223372036854775807 ms.
1807 [main] INFO  kafka.network.Acceptor  - Awaiting socket connections on 0.0.0.0:41274.
1808 [main] INFO  kafka.network.SocketServer  - [Socket Server on Broker 0], Started
1866 [main] INFO  kafka.utils.Mx4jLoader$  - Will not load MX4J, mx4j-tools.jar is not in the classpath
1868 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Controller starting up
1910 [main] INFO  kafka.server.ZookeeperLeaderElector  - 0 successfully elected as leader
1911 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Broker 0 starting become controller state transition
1914 [ProcessThread(sid:0 cport:-1):] INFO  org.apache.zookeeper.server.PrepRequestProcessor  - Got user-level KeeperException when processing sessionid:0x153ef385acf0000 type:setData cxid:0x1a zxid:0xf txntype:-1 reqpath:n/a Error Path:/controller_epoch Error:KeeperErrorCode = NoNode for /controller_epoch
1934 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Controller 0 incremented epoch to 1
1962 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Partitions undergoing preferred replica election: 
1963 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Partitions that completed preferred replica election: 
1964 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Resuming preferred replica election for partitions: 
1967 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Partitions being reassigned: Map()
1968 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Partitions already reassigned: List()
1971 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Resuming reassignment of partitions: Map()
1975 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: List of topics to be deleted: 
1976 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: List of topics ineligible for deletion: 
1979 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Currently active brokers in the cluster: Set()
1980 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Currently shutting brokers in the cluster: Set()
1980 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Current list of topics in the cluster: Set()
1983 [main] INFO  kafka.controller.ReplicaStateMachine  - [Replica state machine on controller 0]: Started replica state machine with initial state -> Map()
1988 [main] INFO  kafka.controller.PartitionStateMachine  - [Partition state machine on Controller 0]: Started partition state machine with initial state -> Map()
1989 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Broker 0 is ready to serve as the new controller with epoch 1
1991 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Starting preferred replica leader election for partitions 
1992 [main] INFO  kafka.controller.PartitionStateMachine  - [Partition state machine on Controller 0]: Invoking state change to OnlinePartition for partitions 
1995 [ProcessThread(sid:0 cport:-1):] INFO  org.apache.zookeeper.server.PrepRequestProcessor  - Got user-level KeeperException when processing sessionid:0x153ef385acf0000 type:delete cxid:0x27 zxid:0x11 txntype:-1 reqpath:n/a Error Path:/admin/preferred_replica_election Error:KeeperErrorCode = NoNode for /admin/preferred_replica_election
2011 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: starting the partition rebalance scheduler
2013 [main] INFO  kafka.controller.KafkaController  - [Controller 0]: Controller startup complete
2042 [main] INFO  kafka.utils.ZkUtils$  - Registered broker 0 at path /brokers/ids/0 with address localhost:41274.
2059 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 0], started
2059 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - Starting broker with id 1
2060 [main] INFO  kafka.utils.VerifiableProperties  - Verifying properties
2060 [main] INFO  kafka.utils.VerifiableProperties  - Property advertised.host.name is overridden to localhost
2060 [main] INFO  kafka.utils.VerifiableProperties  - Property broker.id is overridden to 1
2060 [main] INFO  kafka.utils.VerifiableProperties  - Property log.dir is overridden to /tmp/kafkaITcase-kafka-dirb3ceca9d-080c-4be6-80c5-57c989b65e7e/server-1
2061 [main] INFO  kafka.utils.VerifiableProperties  - Property message.max.bytes is overridden to 52428800
2061 [main] INFO  kafka.utils.VerifiableProperties  - Property port is overridden to 38666
2061 [main] INFO  kafka.utils.VerifiableProperties  - Property replica.fetch.max.bytes is overridden to 52428800
2061 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connect is overridden to 127.0.0.1:39234
2061 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connection.timeout.ms is overridden to 30000
2062 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.session.timeout.ms is overridden to 30000
2062 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 1], starting
2062 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 1], Connecting to zookeeper on 127.0.0.1:39234
2062 [main] INFO  org.apache.zookeeper.ZooKeeper  - Initiating client connection, connectString=127.0.0.1:39234 sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@35dab4eb
2062 [ZkClient-EventThread-56-127.0.0.1:39234] INFO  org.I0Itec.zkclient.ZkEventThread  - Starting ZkClient event thread.
2063 [main] INFO  org.I0Itec.zkclient.ZkClient  - Waiting for keeper state SyncConnected
2063 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Opening socket connection to server 127.0.0.1/127.0.0.1:39234. Will not attempt to authenticate using SASL (unknown error)
2064 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Socket connection established to 127.0.0.1/127.0.0.1:39234, initiating session
2064 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.NIOServerCnxnFactory  - Accepted socket connection from /127.0.0.1:55715
2065 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Client attempting to establish new session at /127.0.0.1:55715
2074 [SyncThread:0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Established session 0x153ef385acf0001 with negotiated timeout 30000 for client /127.0.0.1:55715
2075 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Session establishment complete on server 127.0.0.1/127.0.0.1:39234, sessionid = 0x153ef385acf0001, negotiated timeout = 30000
2075 [main-EventThread] INFO  org.I0Itec.zkclient.ZkClient  - zookeeper state changed (SyncConnected)
2082 [main] INFO  kafka.log.LogManager  - Loading logs.
2083 [main] INFO  kafka.log.LogManager  - Logs loading complete.
2083 [main] INFO  kafka.log.LogManager  - Starting log cleanup with a period of 300000 ms.
2083 [main] INFO  kafka.log.LogManager  - Starting log flusher with a default period of 9223372036854775807 ms.
2087 [main] INFO  kafka.network.Acceptor  - Awaiting socket connections on 0.0.0.0:38666.
2088 [main] INFO  kafka.network.SocketServer  - [Socket Server on Broker 1], Started
2094 [main] INFO  kafka.utils.Mx4jLoader$  - Will not load MX4J, mx4j-tools.jar is not in the classpath
2094 [main] INFO  kafka.controller.KafkaController  - [Controller 1]: Controller starting up
2104 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.server.ZookeeperLeaderElector$LeaderChangeListener  - New leader is 0
2108 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0
2110 [main] INFO  kafka.controller.KafkaController  - [Controller 1]: Controller startup complete
2126 [main] INFO  kafka.utils.ZkUtils$  - Registered broker 1 at path /brokers/ids/1 with address localhost:38666.
2126 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 1], started
2126 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - Starting broker with id 2
2127 [main] INFO  kafka.utils.VerifiableProperties  - Verifying properties
2128 [main] INFO  kafka.utils.VerifiableProperties  - Property advertised.host.name is overridden to localhost
2129 [main] INFO  kafka.utils.VerifiableProperties  - Property broker.id is overridden to 2
2129 [main] INFO  kafka.utils.VerifiableProperties  - Property log.dir is overridden to /tmp/kafkaITcase-kafka-dirb3ceca9d-080c-4be6-80c5-57c989b65e7e/server-2
2129 [main] INFO  kafka.utils.VerifiableProperties  - Property message.max.bytes is overridden to 52428800
2130 [main] INFO  kafka.utils.VerifiableProperties  - Property port is overridden to 57930
2130 [main] INFO  kafka.utils.VerifiableProperties  - Property replica.fetch.max.bytes is overridden to 52428800
2130 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connect is overridden to 127.0.0.1:39234
2131 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.connection.timeout.ms is overridden to 30000
2131 [main] INFO  kafka.utils.VerifiableProperties  - Property zookeeper.session.timeout.ms is overridden to 30000
2132 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 2], starting
2132 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 2], Connecting to zookeeper on 127.0.0.1:39234
2132 [main] INFO  org.apache.zookeeper.ZooKeeper  - Initiating client connection, connectString=127.0.0.1:39234 sessionTimeout=30000 watcher=org.I0Itec.zkclient.ZkClient@909217e
2133 [ZkClient-EventThread-80-127.0.0.1:39234] INFO  org.I0Itec.zkclient.ZkEventThread  - Starting ZkClient event thread.
2133 [main] INFO  org.I0Itec.zkclient.ZkClient  - Waiting for keeper state SyncConnected
2134 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Opening socket connection to server 127.0.0.1/127.0.0.1:39234. Will not attempt to authenticate using SASL (unknown error)
2134 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.NIOServerCnxnFactory  - Accepted socket connection from /127.0.0.1:55716
2134 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Socket connection established to 127.0.0.1/127.0.0.1:39234, initiating session
2136 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:39234] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Client attempting to establish new session at /127.0.0.1:55716
2138 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Newly added brokers: 0, deleted brokers: , all live brokers: 0
2141 [SyncThread:0] INFO  org.apache.zookeeper.server.ZooKeeperServer  - Established session 0x153ef385acf0002 with negotiated timeout 30000 for client /127.0.0.1:55716
2141 [main-SendThread(127.0.0.1:39234)] INFO  org.apache.zookeeper.ClientCnxn  - Session establishment complete on server 127.0.0.1/127.0.0.1:39234, sessionid = 0x153ef385acf0002, negotiated timeout = 30000
2142 [main-EventThread] INFO  org.I0Itec.zkclient.ZkClient  - zookeeper state changed (SyncConnected)
2145 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-0-send-thread], Controller 0 connected to id:0,host:localhost,port:41274 for sending state change requests
2145 [main] INFO  kafka.log.LogManager  - Loading logs.
2146 [main] INFO  kafka.log.LogManager  - Logs loading complete.
2146 [main] INFO  kafka.log.LogManager  - Starting log cleanup with a period of 300000 ms.
2147 [main] INFO  kafka.log.LogManager  - Starting log flusher with a default period of 9223372036854775807 ms.
2147 [Controller-0-to-broker-0-send-thread] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-0-send-thread], Starting 
2147 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.KafkaController  - [Controller 0]: New broker startup callback for 0
2150 [main] INFO  kafka.network.Acceptor  - Awaiting socket connections on 0.0.0.0:57930.
2151 [main] INFO  kafka.network.SocketServer  - [Socket Server on Broker 2], Started
2153 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0,1
2156 [main] INFO  kafka.utils.Mx4jLoader$  - Will not load MX4J, mx4j-tools.jar is not in the classpath
2156 [main] INFO  kafka.controller.KafkaController  - [Controller 2]: Controller starting up
2165 [main] INFO  kafka.controller.KafkaController  - [Controller 2]: Controller startup complete
2175 [main] INFO  kafka.utils.ZkUtils$  - Registered broker 2 at path /brokers/ids/2 with address localhost:57930.
2175 [main] INFO  kafka.server.KafkaServer  - [Kafka Server 2], started
2175 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl  - ZK and KafkaServer started.
2181 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Newly added brokers: 1, deleted brokers: , all live brokers: 0,1
2182 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-1-send-thread], Controller 0 connected to id:1,host:localhost,port:38666 for sending state change requests
2182 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.KafkaController  - [Controller 0]: New broker startup callback for 1
2182 [Controller-0-to-broker-1-send-thread] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-1-send-thread], Starting 
2184 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Broker change listener fired for path /brokers/ids with children 0,1,2
2202 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.ReplicaStateMachine$BrokerChangeListener  - [BrokerChangeListener on Controller 0]: Newly added brokers: 2, deleted brokers: , all live brokers: 0,1,2
2203 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-2-send-thread], Controller 0 connected to id:2,host:localhost,port:57930 for sending state change requests
2204 [ZkClient-EventThread-29-127.0.0.1:39234] INFO  kafka.controller.KafkaController  - [Controller 0]: New broker startup callback for 2
2204 [Controller-0-to-broker-2-send-thread] INFO  kafka.controller.RequestSendThread  - [Controller-0-to-broker-2-send-thread], Starting 
2225 [main] INFO  org.apache.flink.runtime.minicluster.FlinkMiniCluster  - Starting FlinkMiniCluster.
2585 [flink-akka.actor.default-dispatcher-2] INFO  akka.event.slf4j.Slf4jLogger  - Slf4jLogger started
2636 [flink-akka.actor.default-dispatcher-2] INFO  Remoting  - Starting remoting
2795 [flink-akka.actor.default-dispatcher-2] INFO  Remoting  - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:1424]
2816 [main] INFO  org.apache.flink.runtime.blob.BlobServer  - Created BLOB server storage directory /tmp/blobStore-710c6857-9fbd-4fd3-b581-78257ef11788
2823 [main] INFO  org.apache.flink.runtime.blob.BlobServer  - Started BLOB server at 0.0.0.0:53159 - max concurrent requests: 50 - max backlog: 1000
2834 [main] INFO  org.apache.flink.runtime.checkpoint.SavepointStoreFactory  - Using job manager savepoint state backend.
2855 [flink-akka.actor.default-dispatcher-3] INFO  org.apache.flink.runtime.testingUtils.TestingMemoryArchivist  - Started memory archivist akka://flink/user/archive
2858 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingJobManager  - Starting JobManager at akka.tcp://flink@127.0.0.1:1424/user/jobmanager.
2860 [flink-akka.actor.default-dispatcher-2] INFO  akka.event.slf4j.Slf4jLogger  - Slf4jLogger started
2865 [flink-akka.actor.default-dispatcher-2] INFO  Remoting  - Starting remoting
2873 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingJobManager  - JobManager akka.tcp://flink@127.0.0.1:1424/user/jobmanager was granted leadership with leader session ID None.
2874 [flink-akka.actor.default-dispatcher-4] INFO  Remoting  - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:1724]
2884 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testutils.TestingResourceManager  - Trying to associate with JobManager leader akka.tcp://flink@127.0.0.1:1424/user/jobmanager
2890 [flink-akka.actor.default-dispatcher-4] INFO  akka.event.slf4j.Slf4jLogger  - Slf4jLogger started
2897 [flink-akka.actor.default-dispatcher-5] INFO  Remoting  - Starting remoting
2909 [flink-akka.actor.default-dispatcher-5] INFO  Remoting  - Remoting started; listening on addresses :[akka.tcp://flink@127.0.0.1:1524]
2927 [main] INFO  org.apache.flink.runtime.taskmanager.TaskManager  - Messages between TaskManager and JobManager have a max timeout of 10000 milliseconds
2931 [main] INFO  org.apache.flink.runtime.taskmanager.TaskManager  - Temporary file directory '/tmp': total 49 GB, usable 6 GB (12.24% usable)
2961 [main] INFO  org.apache.flink.runtime.io.network.buffer.NetworkBufferPool  - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768).
2962 [main] INFO  org.apache.flink.runtime.taskmanager.TaskManager  - Limiting managed memory to 16 MB, memory will be allocated lazily.
2969 [main] INFO  org.apache.flink.runtime.io.disk.iomanager.IOManager  - I/O manager uses directory /tmp/flink-io-f8b2baa1-9ec5-4eb7-998f-9353ed26ec1e for spill files.
2986 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.filecache.FileCache  - User file cache uses directory /tmp/flink-dist-cache-60cb358f-fdcd-4ab0-b936-0116bd6d9753
3095 [flink-akka.actor.default-dispatcher-2] INFO  org.apache.flink.runtime.testutils.TestingResourceManager  - Resource Manager associating with leading JobManager Actor[akka.tcp://flink@127.0.0.1:1424/user/jobmanager#-1526776305] - leader session null
3140 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - Starting TaskManager actor at akka://flink/user/taskmanager0#1565243646.
3141 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - TaskManager data connection information: gao-wse.jf.intel.com (dataPort=1624)
3142 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - TaskManager has 8 task slot(s).
3143 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - Memory usage stats: [HEAP: 139/377/711 MB, NON HEAP: 45/46/-1 MB (used/committed/max)]
3152 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - Trying to register at JobManager akka.tcp://flink@127.0.0.1:1424/user/jobmanager (attempt 1, timeout: 500 milliseconds)
3194 [flink-akka.actor.default-dispatcher-3] INFO  org.apache.flink.runtime.instance.InstanceManager  - Registered TaskManager at gao-wse (akka.tcp://flink@127.0.0.1:1524/user/taskmanager0) as f307ff03f49d2323b3159683c4a48a71. Current number of registered hosts is 1. Current number of alive task slots is 8.
3204 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - Successful registration at JobManager (akka.tcp://flink@127.0.0.1:1424/user/jobmanager), starting network stack and library cache.
3217 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.testingUtils.TestingTaskManager  - Determined BLOB server address to be /127.0.0.1:53159. Starting BLOB cache.
3218 [flink-akka.actor.default-dispatcher-4] INFO  org.apache.flink.runtime.blob.BlobCache  - Created BLOB cache storage directory /tmp/blobStore-2de04762-43b9-4091-aba5-33b5450aea0d
3227 [main] INFO  org.apache.flink.streaming.connectors.kafka.Kafka08ITCase  - 
================================================================================
Test testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase) is running.
--------------------------------------------------------------------------------
3256 [Thread-14] INFO  org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08  - Trying to get topic metadata from broker localhost:80 in try 0/3
33312 [Thread-14] INFO  kafka.consumer.SimpleConsumer  - Reconnect due to socket error: java.net.SocketTimeoutException
63233 [Thread-14] WARN  org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08  - Error communicating with broker localhost:80 to find partitions for [doesntexist].class java.nio.channels.ClosedByInterruptException. Message: null
63233 [Thread-14] INFO  org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08  - Trying to get topic metadata from broker localhost:80 in try 1/3
63236 [main] ERROR org.apache.flink.streaming.connectors.kafka.Kafka08ITCase  - 
--------------------------------------------------------------------------------
Test testFailOnNoBroker(org.apache.flink.streaming.connectors.kafka.Kafka08ITCase) failed with:
java.lang.Exception: test timed out after 60000 milliseconds
	at sun.nio.ch.Net.poll(Native Method)
	at sun.nio.ch.SocketChannelImpl.poll(SocketChannelImpl.java:954)
	at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:204)
	at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
	at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
	at kafka.utils.Utils$.read(Utils.scala:380)
	at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
	at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
	at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
	at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
	at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
	at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
	at kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
	at kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.getPartitionsForTopic(FlinkKafkaConsumer08.java:521)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:218)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.getConsumer(KafkaTestEnvironmentImpl.java:95)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:65)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:73)
	at org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runFailOnNoBrokerTest(KafkaConsumerTestBase.java:155)
	at org.apache.flink.streaming.connectors.kafka.Kafka08ITCase.testFailOnNoBroker(Kafka08ITCase.java:54)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:497)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.FailOnTimeout$StatementThread.run(FailOnTimeout.java:74)

================================================================================

java.lang.Exception: test timed out after 60000 milliseconds
	at sun.nio.ch.Net.poll(Native Method)
	at sun.nio.ch.SocketChannelImpl.poll(SocketChannelImpl.java:954)
	at sun.nio.ch.SocketAdaptor$SocketInputStream.read(SocketAdaptor.java:204)
	at sun.nio.ch.ChannelInputStream.read(ChannelInputStream.java:103)
	at java.nio.channels.Channels$ReadableByteChannelImpl.read(Channels.java:385)
	at kafka.utils.Utils$.read(Utils.scala:380)
	at kafka.network.BoundedByteBufferReceive.readFrom(BoundedByteBufferReceive.scala:54)
	at kafka.network.Receive$class.readCompletely(Transmission.scala:56)
	at kafka.network.BoundedByteBufferReceive.readCompletely(BoundedByteBufferReceive.scala:29)
	at kafka.network.BlockingChannel.receive(BlockingChannel.scala:111)
	at kafka.consumer.SimpleConsumer.liftedTree1$1(SimpleConsumer.scala:79)
	at kafka.consumer.SimpleConsumer.kafka$consumer$SimpleConsumer$$sendRequest(SimpleConsumer.scala:68)
	at kafka.consumer.SimpleConsumer.send(SimpleConsumer.scala:91)
	at kafka.javaapi.consumer.SimpleConsumer.send(SimpleConsumer.scala:68)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.getPartitionsForTopic(FlinkKafkaConsumer08.java:521)
	at org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer08.<init>(FlinkKafkaConsumer08.java:218)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironmentImpl.getConsumer(KafkaTestEnvironmentImpl.java:95)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:65)
	at org.apache.flink.streaming.connectors.kafka.KafkaTestEnvironment.getConsumer(KafkaTestEnvironment.java:73)
	at org.apache.flink.streaming.connectors.kafka.KafkaConsumerTestBase.runFailOnNoBrokerTest(KafkaConsumerTestBase.java:155)
	at org.apache.flink.streaming.connectors.kafka.Kafka08ITCase.testFailOnNoBroker(Kafka08ITCase.java:54)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:47)
	at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
	at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:44)
	at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
	at org.junit.internal.runners.statements.FailOnTimeout$StatementThread.run(FailOnTimeout.java:74)

63247 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  - -------------------------------------------------------------------------
63247 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  -     Shut down KafkaTestBase 
63247 [main] INFO  org.apache.flink.streaming.connectors.kafka.KafkaTestBase  - -------------------------------------------------------------------------
63345 [flink-akka.actor.default-dispatcher-3] INFO  org.apache.flink.runtime.testingUtils.TestingJobManager  - Stopping JobManager akka.tcp://flink@127.0.0.1:14



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message