Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 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
yup it is my machine works fine from my linux box, ugh.  second hurdle from
my new latop.

no worries will soldier through it

On Fri, Feb 10, 2012 at 10:34 AM, Joe Stein <[EMAIL PROTECTED]> wrote:

> 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)
/*
Joe Stein
http://www.linkedin.com/in/charmalloc
Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop>
*/
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB