[prev in list] [next in list] [prev in thread] [next in thread]
List: cassandra-user
Subject: Re: Avro API on cassandra trunk with ruby
From: Christian van der Leeden <christian.vanderleeden () googlemail ! com>
Date: 2010-06-29 15:50:36
Message-ID: 1B1B3DE7-27E0-485D-8D24-55A2199B7C68 () googlemail ! com
[Download RAW message or body]
Thanks, this works now.
Christian
On Jun 29, 2010, at 5:26 PM, Eric Evans wrote:
> On Tue, 2010-06-29 at 13:10 +0200, Christian van der Leeden wrote:
>> just trying to talk to cassandra-trunk (0.7) via avro on ruby.
>> Started the server with ./bin/cassandra -a -f. The connection
>> code is here: http://pastie.org/1023158
>
> Cassandra uses the HTTP transport (for now anyway), but you're using a
> socket transport. I think you want something more like:
>
> def make_requestor()
> transport = Avro::IPC::HTTPTransceiver.new("localhost", 9160)
> Avro::IPC::Requestor.new(CASSANDRA_PROTOCOL, transport)
> end
>
> See lang/ruby/test/sample_ipc_http_client.rb in Avro's source.
>
>> The problem is that the server says:
>> DEBUG 12:54:44,205 EXCEPTION
>> HttpException(400,null,null)
>> at org.mortbay.jetty.HttpParser.parseNext(HttpParser.java:361)
>> at
>> org.mortbay.jetty.HttpParser.parseAvailable(HttpParser.java:212)
>> at
>> org.mortbay.jetty.HttpConnection.handle(HttpConnection.java:405)
>> at org.mortbay.jetty.bio.SocketConnector
>> $Connection.run(SocketConnector.java:228)
>> at org.mortbay.thread.QueuedThreadPool
>> $PoolThread.run(QueuedThreadPool.java:582)
> --
> Eric Evans
> eevans@rackspace.com
>
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic