Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Kafka, mail # dev - stumped on failing test KAFKA-240


Copy link to this message
-
Re: stumped on failing test KAFKA-240
Joe Stein 2012-02-10, 15:34
thanks Jun, I just went ahead and checked out the 0.8 branch

before making changes on it I went ahead and ./sbt update && ./sbt test

what is weird is it is hanging on and never getting past

[info] == core-kafka / kafka.javaapi.integration.PrimitiveApiTest =[info] Test Starting:
testProduceAndFetch(kafka.javaapi.integration.PrimitiveApiTest)

is anyone else seeing this or is it just me?

On Thu, Feb 9, 2012 at 1:13 PM, Jun Rao <[EMAIL PROTECTED]> wrote:

> Joe,
>
> The producer code has been refactored and simplified in the 0.8 branch
> recently (e.g., producer pool no longer calls syncprodcuer directly). Could
> you rebase you code and retry the tests?
>
> Thanks,
>
> Jun
>
> On Thu, Feb 9, 2012 at 1:34 AM, Joe Stein <[EMAIL PROTECTED]> wrote:
>
> > Hi, I am stumped on what is wrong here my test failures due to something
> in
> > the code path of the pool is getting called differently than directly to
> > sync?
> >
> > any thoughts to what is causing this in my changes I would appreciate
> think
> > it needs a fresh set of eyes (maybe just eyes not so tired)
> >
> > info] == core-kafka / kafka.producer.ProducerTest => > [info] Test Starting: testSend
> > arghhhhh
> > [error] Test Failed: testSend
> > java.lang.AssertionError:
> >  Unexpected method call
> > send(ProducerRequest(0,-1,TODO,0,0:[test-topic:[0,15]])):
> >    send(ProducerRequest(0,-1,TODO,0,0:[test-topic:[0,15]])): expected: 1,
> > actual: 0
> >    close(): expected: 1, actual: 0
> > at
> >
> >
> org.easymock.internal.MockInvocationHandler.invoke(MockInvocationHandler.java:45)
> > at
> >
> >
> org.easymock.internal.ObjectMethodsFilter.invoke(ObjectMethodsFilter.java:73)
> > at
> >
> >
> org.easymock.internal.ClassProxyFactory$MockMethodInterceptor.intercept(ClassProxyFactory.java:92)
> > at
> kafka.producer.SyncProducer$$EnhancerByCGLIB$$f15397e4.send(<generated>)
> > at
> >
> >
> kafka.producer.ProducerPool$$anonfun$send$1.apply$mcVI$sp(ProducerPool.scala:126)
> > at
> > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
> > at
> > kafka.producer.ProducerPool$$anonfun$send$1.apply(ProducerPool.scala:102)
> > at
> >
> >
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:57)
> > at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:43)
> > at kafka.producer.ProducerPool.send(ProducerPool.scala:102)
> > at kafka.producer.Producer.zkSend(Producer.scala:143)
> > at kafka.producer.Producer.send(Producer.scala:105)
> > at kafka.producer.ProducerTest.testSend(ProducerTest.scala:138)
> > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> > at
> >
> >
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
> > at
> >
> >
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
> > at java.lang.reflect.Method.invoke(Method.java:597)
> > at
> >
> >
> org.junit.internal.runners.TestMethodRunner.executeMethodBody(TestMethodRunner.java:99)
> > at
> >
> >
> org.junit.internal.runners.TestMethodRunner.runUnprotected(TestMethodRunner.java:81)
> > at
> >
> >
> org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34)
> > at
> >
> >
> org.junit.internal.runners.TestMethodRunner.runMethod(TestMethodRunner.java:75)
> > at
> > org.junit.internal.runners.TestMethodRunner.run(TestMethodRunner.java:45)
> > at
> >
> >
> org.junit.internal.runners.TestClassMethodsRunner.invokeTestMethod(TestClassMethodsRunner.java:71)
> > at
> >
> >
> org.junit.internal.runners.TestClassMethodsRunner.run(TestClassMethodsRunner.java:35)
> > at
> >
> >
> org.junit.internal.runners.TestClassRunner$1.runUnprotected(TestClassRunner.java:42)
> > at
> >
> >
> org.junit.internal.runners.BeforeAndAfterRunner.runProtected(BeforeAndAfterRunner.java:34)
> > at
> org.junit.internal.runners.TestClassRunner.run(TestClassRunner.java:52)
> > at
> org.junit.internal.runners.CompositeRunner.run(CompositeRunner.java:29)
> > at org.junit.runner.JUnitCore.run(JUnitCore.java:121)
/*
Joe Stein
http://www.linkedin.com/in/charmalloc
Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
*/