Note that there are some explanatory texts on larger screens.

plurals
  1. POCassandra's thrift transport exception
    primarykey
    data
    text
    <p>I have an exception occurred, using cassandra with thrift. I want to insert some data. Here is the java code:</p> <pre><code>package pacan.java.eee; import java.nio.ByteBuffer; import org.apache.cassandra.thrift.Cassandra; import org.apache.cassandra.thrift.Column; import org.apache.cassandra.thrift.ColumnParent; import org.apache.cassandra.thrift.ConsistencyLevel; import org.apache.cassandra.thrift.InvalidRequestException; import org.apache.cassandra.thrift.NotFoundException; import org.apache.cassandra.thrift.TBinaryProtocol; import org.apache.cassandra.thrift.TimedOutException; import org.apache.cassandra.thrift.UnavailableException; import org.apache.thrift.TException; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.transport.TFramedTransport; import org.apache.thrift.transport.TSocket; import org.apache.thrift.transport.TTransport; public class Main { private static final String UTF8 = "UTF8"; /** * @param args * @throws TException * @throws InvalidRequestException * @throws NotFoundException * @throws TimedOutException * @throws UnavailableException */ public static void main(String[] args) throws InvalidRequestException, TException, NotFoundException, UnavailableException, TimedOutException { TTransport tr = new TFramedTransport(new TSocket("localhost", 7199)); TProtocol protocol = new TBinaryProtocol(tr); Cassandra.Client client = new Cassandra.Client(protocol); tr.open(); client.set_keyspace("keyspace"); ColumnParent colParent = new ColumnParent("User"); ByteBuffer rowid = ByteBuffer.wrap("100".getBytes()); Column column = new Column(); column.setName("description".getBytes()); column.setValue("some value".getBytes()); column.setTimestamp(System.currentTimeMillis()); client.insert(rowid, colParent, column, ConsistencyLevel.ONE); tr.flush(); tr.close(); } } </code></pre> <p>And here is the exception I got:</p> <pre><code>Exception in thread "main" 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.thrift.TServiceClient.receiveBase(TServiceClient.java:69) at org.apache.cassandra.thrift.Cassandra$Client.recv_set_keyspace(Cassandra.java:493) at org.apache.cassandra.thrift.Cassandra$Client.set_keyspace(Cassandra.java:480) at pacan.java.eee.Main.main(Main.java:37) </code></pre> <p>Help, please! =) I've already google it, and wasn't able to find an answer.</p>
    singulars
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    plurals
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
    1. This table or related slice is empty.
 

Querying!

 
Guidance

SQuiL has stopped working due to an internal error.

If you are curious you may find further information in the browser console, which is accessible through the devtools (F12).

Reload