In your code you are using BufferedTransport, but in the Cassandra logs
you're getting errors when it tries to use FramedTransport. If I remember
correctly, BufferedTransport is gone, so you should only use
FramedTransport. Like this:
TTransport transport = new TFramedTransport(new TSocket(host, port));
TProtocol protocol = new TBinaryProtocol(transport);
var client = new Cassandra.Client(protocol);
transport.Open();
client.describe_keyspace("abc");
/Henrik
On Tue, Apr 10, 2012 at 11:23, puneet loya <puneetl...@gmail.com> wrote:
>
> Log is showing the following exception
>
> DEBUG [ScheduledTasks:1] 2012-04-10 14:49:29,654 LoadBroadcaster.java
> (line 86) Disseminating load info ...
> DEBUG [Thrift:7] 2012-04-10 14:50:00,820 CustomTThreadPoolServer.java
> (line 197) Thrift transport error occurred during processing of message.
> org.apache.thrift.transport.TTransportException
> at
> org.apache.thrift.transport.TIOStreamTransport.read(TIOStreamTransport.java:132)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at
> org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:129)
> at
> org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
> at org.apache.thrift.transport.TTransport.readAll(TTransport.java:84)
> at
> org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:378)
> at
> org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:297)
> at
> org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:204)
> at
> org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2877)
> at
> org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:187)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
> at java.lang.Thread.run(Unknown Source)
> DEBUG [Thrift:7] 2012-04-10 14:50:00,820 ClientState.java (line 104)
> logged out: #<User allow_all groups=[]>
>
> On Tue, Apr 10, 2012 at 11:24 AM, Maki Watanabe
> <watanabe.m...@gmail.com>wrote:
>
>> Check your cassandra log.
>> If you can't find any interesting log, set cassandra log level
>> to DEBUG and run your program again.
>>
>> maki
>>
>> 2012/4/10 puneet loya <puneetl...@gmail.com>:
>> > hi,
>> >
>> > sorry i posted the port as 7000. I m using 9160 but still has the same
>> > error.
>> >
>> > "Cannot read, Remote side has closed".
>> > Can u guess whats happening??
>> >
>> > On Tue, Apr 10, 2012 at 11:00 AM, Pierre Chalamet <pie...@chalamet.net>
>> > wrote:
>> >>
>> >> hello,
>> >>
>> >> 9160 is probably the port to use if you use the default config.
>> >>
>> >> - Pierre
>> >>
>> >> On Apr 10, 2012, at 7:26 AM, puneet loya <puneetl...@gmail.com> wrote:
>> >>
>> >> > using System;
>> >> > using System.Collections.Generic;
>> >> > using System.Linq;
>> >> > using System.Text;
>> >> > using Thrift.Collections;
>> >> > using Thrift.Protocol;
>> >> > using Thrift.Transport;
>> >> > using Apache.Cassandra;
>> >> >
>> >> > namespace ConsoleApplication1
>> >> > {
>> >> > class Program
>> >> > {
>> >> > static void Main(string[] args)
>> >> > {
>> >> > TTransport transport=null;
>> >> > try
>> >> > {
>> >> > transport = new TBufferedTransport(new
>> >> > TSocket("127.0.0.1", 7000));
>> >> >
>> >> >
>> >> > //if(buffered)
>> >> > // trans = new TBufferedTransport(trans as
>> >> > TStreamTransport);
>> >> > //if (framed)
>> >> > // trans = new TFramedTransport(trans);
>> >> >
>> >> > TProtocol protocol = new TBinaryProtocol(transport);
>> >> > Cassandra.Client client = new
>> >> > Cassandra.Client(protocol);
>> >> >
>> >> > Console.WriteLine("Opening connection");
>> >> >
>> >> > if (!transport.IsOpen)
>> >> > transport.Open();
>> >> >
>> >> > client.describe_keyspace("abc"); //
>> >> > Crashing at this point
>> >> >
>> >> > }
>> >> > catch (Exception ex)
>> >> > {
>> >> > Console.WriteLine(ex.Message);
>> >> > }
>> >> > finally
>> >> > { if(transport!=null)
>> >> > transport.Close(); }
>> >> > Console.ReadLine();
>> >> > }
>> >> > }
>> >> > }
>> >> >
>> >> > I m trying to interact with cassandra server(database) from .net. For
>> >> > that i have referred two libraries i.e, apacheCassandra08.dll and
>> >> > thrift.dll.. In the following piece of code the connection is
>> getting opened
>> >> > but when i m using client object it is giving an error stating
>> "Cannot read,
>> >> > Remote side has closed".
>> >> >
>> >> > Can any1 help me out with this? Has any1 faced the same prob?
>> >> >
>> >> >
>> >
>> >
>>
>
>
