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://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]:1724]
2884 [flink-akka.actor.default-dispatcher-4] INFO
org.apache.flink.runtime.testutils.TestingResourceManager - Trying to
associate with JobManager leader akka.tcp://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]: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://[email protected]:14
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
