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 < [email protected]> wrote: > 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 >
