You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Ismael Juma (JIRA)" <ji...@apache.org> on 2016/06/20 13:42:05 UTC
[jira] [Updated] (KAFKA-3875) Transient test failure:
kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime
[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Ismael Juma updated KAFKA-3875:
-------------------------------
Description:
It failed in a couple of builds.
{code}
java.lang.AssertionError: Should have offset 100 but only successfully sent 0 expected:<100> but was:<0>
at org.junit.Assert.fail(Assert.java:88)
at org.junit.Assert.failNotEquals(Assert.java:834)
at org.junit.Assert.assertEquals(Assert.java:645)
at kafka.api.BaseProducerSendTest.sendAndVerifyTimestamp(BaseProducerSendTest.scala:228)
at kafka.api.BaseProducerSendTest.testSendNonCompressedMessageWithCreateTime(BaseProducerSendTest.scala:170)
{code}
And standard out:
{code}
org.scalatest.junit.JUnitTestFailedError: Send callback returns the following exception
at org.scalatest.junit.AssertionsForJUnit$class.newAssertionFailedException(AssertionsForJUnit.scala:103)
at org.scalatest.junit.JUnitSuite.newAssertionFailedException(JUnitSuite.scala:79)
at org.scalatest.Assertions$class.fail(Assertions.scala:1348)
at org.scalatest.junit.JUnitSuite.fail(JUnitSuite.scala:79)
at kafka.api.BaseProducerSendTest$callback$4$.onCompletion(BaseProducerSendTest.scala:209)
at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:109)
at org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:155)
at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortExpiredBatches(RecordAccumulator.java:245)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:211)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
at java.lang.Thread.run(Thread.java:745)
Caused by: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for topic-0
java.lang.IllegalStateException: Cannot send after the producer is closed.
at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:172)
at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:466)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430)
at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:353)
at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
at scala.collection.immutable.Range.foreach(Range.scala:160)
at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
at scala.collection.AbstractTraversable.map(Traversable.scala:104)
at kafka.api.BaseProducerSendTest$CloseCallback$1.onCompletion(BaseProducerSendTest.scala:415)
at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:107)
at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:318)
at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:278)
at org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:57)
at org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:364)
at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
at java.lang.Thread.run(Thread.java:745)
{code}
https://jenkins.confluent.io/job/kafka-trunk/905/
https://jenkins.confluent.io/job/kafka-trunk/919 (the output is similar to the first build)
was:
It failed in a couple of builds:
https://jenkins.confluent.io/job/kafka-trunk/905/
https://jenkins.confluent.io/job/kafka-trunk/919
> Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime
> ------------------------------------------------------------------------------------------------
>
> Key: KAFKA-3875
> URL: https://issues.apache.org/jira/browse/KAFKA-3875
> Project: Kafka
> Issue Type: Sub-task
> Components: unit tests
> Reporter: Ismael Juma
> Labels: transient-unit-test-failure
>
> It failed in a couple of builds.
> {code}
> java.lang.AssertionError: Should have offset 100 but only successfully sent 0 expected:<100> but was:<0>
> at org.junit.Assert.fail(Assert.java:88)
> at org.junit.Assert.failNotEquals(Assert.java:834)
> at org.junit.Assert.assertEquals(Assert.java:645)
> at kafka.api.BaseProducerSendTest.sendAndVerifyTimestamp(BaseProducerSendTest.scala:228)
> at kafka.api.BaseProducerSendTest.testSendNonCompressedMessageWithCreateTime(BaseProducerSendTest.scala:170)
> {code}
> And standard out:
> {code}
> org.scalatest.junit.JUnitTestFailedError: Send callback returns the following exception
> at org.scalatest.junit.AssertionsForJUnit$class.newAssertionFailedException(AssertionsForJUnit.scala:103)
> at org.scalatest.junit.JUnitSuite.newAssertionFailedException(JUnitSuite.scala:79)
> at org.scalatest.Assertions$class.fail(Assertions.scala:1348)
> at org.scalatest.junit.JUnitSuite.fail(JUnitSuite.scala:79)
> at kafka.api.BaseProducerSendTest$callback$4$.onCompletion(BaseProducerSendTest.scala:209)
> at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:109)
> at org.apache.kafka.clients.producer.internals.RecordBatch.maybeExpire(RecordBatch.java:155)
> at org.apache.kafka.clients.producer.internals.RecordAccumulator.abortExpiredBatches(RecordAccumulator.java:245)
> at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:211)
> at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for topic-0
> java.lang.IllegalStateException: Cannot send after the producer is closed.
> at org.apache.kafka.clients.producer.internals.RecordAccumulator.append(RecordAccumulator.java:172)
> at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:466)
> at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:430)
> at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:353)
> at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
> at kafka.api.BaseProducerSendTest$CloseCallback$1$$anonfun$onCompletion$1.apply(BaseProducerSendTest.scala:415)
> at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234)
> at scala.collection.immutable.Range.foreach(Range.scala:160)
> at scala.collection.TraversableLike$class.map(TraversableLike.scala:234)
> at scala.collection.AbstractTraversable.map(Traversable.scala:104)
> at kafka.api.BaseProducerSendTest$CloseCallback$1.onCompletion(BaseProducerSendTest.scala:415)
> at org.apache.kafka.clients.producer.internals.RecordBatch.done(RecordBatch.java:107)
> at org.apache.kafka.clients.producer.internals.Sender.completeBatch(Sender.java:318)
> at org.apache.kafka.clients.producer.internals.Sender.handleProduceResponse(Sender.java:278)
> at org.apache.kafka.clients.producer.internals.Sender.access$100(Sender.java:57)
> at org.apache.kafka.clients.producer.internals.Sender$1.onComplete(Sender.java:364)
> at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:278)
> at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:235)
> at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:134)
> at java.lang.Thread.run(Thread.java:745)
> {code}
> https://jenkins.confluent.io/job/kafka-trunk/905/
> https://jenkins.confluent.io/job/kafka-trunk/919 (the output is similar to the first build)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)