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

Switch to Plain View
Avro >> mail # user >> what's the purpose of one-way, and why does it cause problems with python?

Mark Lewandowski 2010-10-30, 02:28
Doug Cutting 2010-11-01, 17:50
Doug Cutting 2010-11-01, 18:00
Copy link to this message
Re: what's the purpose of one-way, and why does it cause problems with python?
The Python support for Avro RPC does not currently support the oneway stuff.
 According to hammer, Henry was working on it at a recent hackathon, so
hopefully someone will have some more useful information for you on Monday!

 - Bruce

On Sat, Oct 30, 2010 at 9:28 AM, Mark Lewandowski <

> I'm writing a python app to talk to flume using the new avroSource feature,
> and I'm running into an issue when when communicating between flume (written
> in java) and my python script.  I've taken the flume.avpr schema file from
> flume and used it to communicate between two python processes without any
> problems, but as soon as I try to communicate with flume I get an error
> saying:
>     org.apache.avro.AvroRuntimeException: Not both one-way: append
> I can't find any mention of the one-way flag in the python bindings for
> avro, so I'm guessing that this flag is not getting set when the rpc call is
> sent across the wire, causing Responder.java to throw the above exception.
> I've checked, and the java implementation of ipc.Responder checks to see
> that both the local and remote messages oneWay property are set to identical
> values.
> I've been stuck on this problem for a day now, so any help would be greatly
> appreciated.
> Thanks,
> -Mark