[
https://issues.apache.org/jira/browse/KAFKA-4184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang reopened KAFKA-4184:
----------------------------------
This test failed again:
https://builds.apache.org/job/kafka-trunk-git-pr-jdk7/5905/testReport/junit/kafka.server/ReplicationQuotasTest/shouldBootstrapTwoBrokersWithLeaderThrottle/
{code}
Stacktrace
java.lang.AssertionError: Offsets did not match for partition 6 on broker 106
at org.junit.Assert.fail(Assert.java:88)
at kafka.utils.TestUtils$.waitUntilTrue(TestUtils.scala:752)
at
kafka.server.ReplicationQuotasTest.kafka$server$ReplicationQuotasTest$$waitForOffsetsToMatch(ReplicationQuotasTest.scala:217)
at
kafka.server.ReplicationQuotasTest$$anonfun$shouldMatchQuotaReplicatingThroughAnAsymmetricTopology$7.apply$mcZI$sp(ReplicationQuotasTest.scala:144)
at
kafka.server.ReplicationQuotasTest$$anonfun$shouldMatchQuotaReplicatingThroughAnAsymmetricTopology$7.apply(ReplicationQuotasTest.scala:144)
at
kafka.server.ReplicationQuotasTest$$anonfun$shouldMatchQuotaReplicatingThroughAnAsymmetricTopology$7.apply(ReplicationQuotasTest.scala:144)
at scala.collection.immutable.Range.foreach(Range.scala:160)
at
kafka.server.ReplicationQuotasTest.shouldMatchQuotaReplicatingThroughAnAsymmetricTopology(ReplicationQuotasTest.scala:144)
at
kafka.server.ReplicationQuotasTest.shouldBootstrapTwoBrokersWithLeaderThrottle(ReplicationQuotasTest.scala:68)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:78)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:57)
at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.runTestClass(JUnitTestClassExecuter.java:114)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassExecuter.execute(JUnitTestClassExecuter.java:57)
at
org.gradle.api.internal.tasks.testing.junit.JUnitTestClassProcessor.processTestClass(JUnitTestClassProcessor.java:66)
at
org.gradle.api.internal.tasks.testing.SuiteTestClassProcessor.processTestClass(SuiteTestClassProcessor.java:51)
at sun.reflect.GeneratedMethodAccessor15.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.dispatch.ContextClassLoaderDispatch.dispatch(ContextClassLoaderDispatch.java:32)
at
org.gradle.internal.dispatch.ProxyDispatchAdapter$DispatchingInvocationHandler.invoke(ProxyDispatchAdapter.java:93)
at com.sun.proxy.$Proxy2.processTestClass(Unknown Source)
at
org.gradle.api.internal.tasks.testing.worker.TestWorker.processTestClass(TestWorker.java:109)
at sun.reflect.GeneratedMethodAccessor14.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:606)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:35)
at
org.gradle.internal.dispatch.ReflectionDispatch.dispatch(ReflectionDispatch.java:24)
at
org.gradle.internal.remote.internal.hub.MessageHub$Handler.run(MessageHub.java:377)
at
org.gradle.internal.concurrent.ExecutorPolicy$CatchAndRecordFailures.onExecute(ExecutorPolicy.java:54)
at
org.gradle.internal.concurrent.StoppableExecutorImpl$1.run(StoppableExecutorImpl.java:40)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
Standard Output
[2016-09-27 16:01:07,484] WARN Client session timed out, have not heard from
server in 28053ms for sessionid 0x1576c6064670000
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,493] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c6064670000, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:01:07,520] WARN Client session timed out, have not heard from
server in 27689ms for sessionid 0x1576c6064670003
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,520] WARN Client session timed out, have not heard from
server in 27654ms for sessionid 0x1576c6064670004
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,520] WARN Client session timed out, have not heard from
server in 27656ms for sessionid 0x1576c6064670005
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,521] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c6064670003, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:01:07,520] WARN Client session timed out, have not heard from
server in 27691ms for sessionid 0x1576c6064670002
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,520] WARN Client session timed out, have not heard from
server in 27643ms for sessionid 0x1576c6064670006
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,521] WARN Client session timed out, have not heard from
server in 27632ms for sessionid 0x1576c6064670001
(org.apache.zookeeper.ClientCnxn:1108)
[2016-09-27 16:01:07,521] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c6064670004, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:01:07,527] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c6064670006, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:01:07,534] WARN Ignoring unexpected runtime exception
(org.apache.zookeeper.server.NIOServerCnxnFactory:213)
java.nio.channels.CancelledKeyException
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
at sun.nio.ch.SelectionKeyImpl.readyOps(SelectionKeyImpl.java:87)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:182)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:01:08,917] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670006 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,043] ERROR [ReplicaFetcherThread-0-107], Current offset
100 for partition [topic1,5] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,087] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670003 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,273] ERROR [ReplicaFetcherThread-0-106], Current offset
100 for partition [topic1,2] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,319] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670004 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,373] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670001 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,401] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670000 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,419] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670002 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,484] ERROR [ReplicaFetcherThread-0-107], Current offset
100 for partition [topic1,3] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,573] WARN Unable to reconnect to ZooKeeper service,
session 0x1576c6064670005 has expired (org.apache.zookeeper.ClientCnxn:1285)
[2016-09-27 16:01:09,650] ERROR [ReplicaFetcherThread-0-106], Current offset
100 for partition [topic1,0] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,687] ERROR [ReplicaFetcherThread-0-106], Current offset
100 for partition [topic1,6] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,745] ERROR [ReplicaFetcherThread-0-106], Current offset
100 for partition [topic1,1] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,748] ERROR [ReplicaFetcherThread-0-107], Current offset
100 for partition [topic1,7] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:01:09,799] ERROR [ReplicaFetcherThread-0-107], Current offset
100 for partition [topic1,4] out of range; reset offset to 0
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:02:08,717] ERROR [ReplicaFetcherThread-0-100], Error for
partition [topic1,0] to broker
100:org.apache.kafka.common.errors.NotLeaderForPartitionException: This server
is not the leader for that topic-partition.
(kafka.server.ReplicaFetcherThread:97)
[2016-09-27 16:02:18,315] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c61cb840001, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:02:18,321] WARN Ignoring unexpected runtime exception
(org.apache.zookeeper.server.NIOServerCnxnFactory:213)
java.nio.channels.CancelledKeyException
at sun.nio.ch.SelectionKeyImpl.ensureValid(SelectionKeyImpl.java:73)
at sun.nio.ch.SelectionKeyImpl.readyOps(SelectionKeyImpl.java:87)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:182)
at java.lang.Thread.run(Thread.java:745)
[2016-09-27 16:02:32,111] WARN caught end of stream exception
(org.apache.zookeeper.server.NIOServerCnxn:357)
EndOfStreamException: Unable to read additional data from client sessionid
0x1576c61e8550008, likely client has closed socket
at
org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at
org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
{code}
> Test failure in
> ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle
> -----------------------------------------------------------------------------------
>
> Key: KAFKA-4184
> URL: https://issues.apache.org/jira/browse/KAFKA-4184
> Project: Kafka
> Issue Type: Bug
> Components: unit tests
> Reporter: Jason Gustafson
> Assignee: Ben Stopford
> Fix For: 0.10.1.0
>
>
> Seen here: https://builds.apache.org/job/kafka-trunk-jdk7/1544/.
> {code}
> unit.kafka.server.ReplicationQuotasTest >
> shouldBootstrapTwoBrokersWithFollowerThrottle FAILED
> java.lang.AssertionError: expected:<3.0E7> but was:<2.060725619683527E7>
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.failNotEquals(Assert.java:834)
> at org.junit.Assert.assertEquals(Assert.java:553)
> at org.junit.Assert.assertEquals(Assert.java:683)
> at
> unit.kafka.server.ReplicationQuotasTest$$anonfun$shouldMatchQuotaReplicatingThroughAnAsymmetricTopology$14.apply(ReplicationQuotasTest.scala:172)
> at
> unit.kafka.server.ReplicationQuotasTest$$anonfun$shouldMatchQuotaReplicatingThroughAnAsymmetricTopology$14.apply(ReplicationQuotasTest.scala:168)
> at scala.collection.Iterator$class.foreach(Iterator.scala:727)
> at scala.collection.AbstractIterator.foreach(Iterator.scala:1157)
> at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
> at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> at
> unit.kafka.server.ReplicationQuotasTest.shouldMatchQuotaReplicatingThroughAnAsymmetricTopology(ReplicationQuotasTest.scala:168)
> at
> unit.kafka.server.ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle(ReplicationQuotasTest.scala:74)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
