Hey I'm testing a client on beta2 cassandra version 0.7.

        TFramedTransport transport = new TFramedTransport(new
TSocket("my.ip", 9160));
        Cassandra.Client client = new Cassandra.Client(new
TBinaryProtocol(transport));
        transport.open();
        System.out.println(client.describe_cluster_name());

Is giving me the following:

org.apache.thrift.protocol.TProtocolException: Missing version in
readMessageBegin, old client?
        at
org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:211)
        at
org.apache.cassandra.thrift.Cassandra$Processor.process(Cassandra.java:2706)
        at
org.apache.cassandra.thrift.CustomTThreadPoolServer$WorkerProcess.run(CustomTThreadPoolServer.java:167)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
        at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
        at java.lang.Thread.run(Thread.java:662)

I'm using the cassandra 0.7beta2 code on both client and server.

Reply via email to