[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15819602#comment-15819602 ]
Guozhang Wang commented on KAFKA-3875: -------------------------------------- Another failure with different error message: {code} Stacktrace java.lang.AssertionError: No request is complete. at org.junit.Assert.fail(Assert.java:88) at org.junit.Assert.assertTrue(Assert.java:41) at kafka.api.BaseProducerSendTest$$anonfun$testCloseWithZeroTimeoutFromCallerThread$1.apply$mcVI$sp(BaseProducerSendTest.scala:398) at scala.collection.immutable.Range.foreach$mVc$sp(Range.scala:160) at kafka.api.BaseProducerSendTest.testCloseWithZeroTimeoutFromCallerThread(BaseProducerSendTest.scala:395) 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:498) 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.GeneratedMethodAccessor17.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) 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.GeneratedMethodAccessor16.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) 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:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745) {code} > 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 > Assignee: Jun Rao > Labels: transient-unit-test-failure > Fix For: 0.10.2.0 > > > 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)