thankk uuuu :) :) it works :)
On Tue, Apr 10, 2012 at 3:07 PM, Henrik Schröder <skro...@gmail.com> wrote:
> 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?
>>> >> >
>>> >> >
>>> >
>>> >
>>>
>>
>>
>
