Geek asks and answers

How to connect to Kassandra using Hector?

I have the following code:

StringSerializer ss = StringSerializer.get();
String cf = "TEST";
CassandraHostConfigurator conf = new CassandraHostConfigurator("localhost:9160");
conf.setCassandraThriftSocketTimeout(40000);
conf.setExhaustedPolicy(ExhaustedPolicy.WHEN_EXHAUSTED_BLOCK);
conf.setRetryDownedHostsDelayInSeconds(5);
conf.setRetryDownedHostsQueueSize(128);
conf.setRetryDownedHosts(true);
conf.setLoadBalancingPolicy(new LeastActiveBalancingPolicy());
String key = Long.toString(System.currentTimeMillis());
Cluster cluster = HFactory.getOrCreateCluster("TestCluster", conf);
Keyspace keyspace = HFactory.createKeyspace("TestCluster", cluster);
Mutator<String> mutator = HFactory.createMutator(keyspace, StringSerializer.get());    int count = 0;
while (!"q".equals(new Scanner( System.in).next())) {
    try{
        mutator.insert(key, cf, HFactory.createColumn("column_" + count, "v_" + count, ss, ss));
    count++;
    } catch (Exception e) {
        e.printStackTrace();
    }
}

and I can write some values ​​using this, but when I restart cassandra it fails. Here is the log:

[15:11:07] INFO [CassandraHostRetryService] s > 128 5s [15:11:07] INFO [JmxMonitor] JMX > me.prettyprint.cassandra.service_ASG: ServiceType = hector, MonitorType = hector [15:11:17] [HThriftClient] ( > , ), : CassandraClient org.apache.thrift.transport.TTransportException: java.net.SocketException:   at > org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:147)    org.apache.thrift.transport.TFramedTransport.flush(TFramedTransport.java:156)   at > me.prettyprint.cassandra.connection.client.HThriftClient.close(HThriftClient.java:98)   at > me.prettyprint.cassandra.connection.client.HThriftClient.close(HThriftClient.java:26)   at > me.prettyprint.cassandra.connection.HConnectionManager.closeClient(HConnectionManager.java:308)   at > me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:257)   at > me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97)    me.prettyprint.cassandra.model.MutatorImpl.execute(MutatorImpl.java:243)    me.prettyprint.cassandra.model.MutatorImpl.insert(MutatorImpl.java:69)   at com.app.App.main(App.java:40) : java.net.SocketException:    java.net.SocketOutputStream.socketWrite0 ( )    java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109)    java.net.SocketOutputStream.write(SocketOutputStream.java:153)   at > org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:145)   ... 9 [15:11:17] [HConnectionManager] MARK HOST AS DOWN TRIGGERED a > localhost (127.0.0.1): 9160 [15:11:17] [HConnectionManager] : > : {localhost (127.0.0.1): 9160}; IsActive?: true; : 1; : 0; Idle: 15; NumBeforeExhausted: 49 [15:11:17] INFO [ConcurrentHClientPool] : {localhost (127.0.0.1): 9160} [15:11:17] INFO [ConcurrentHClientPool] : {localhost (127.0.0.1): 9160} [15:11:17] INFO [CassandraHostRetryService] , , : localhost (127.0.0.1): 9160 [15:11:17] WARN [HConnectionManager] CassandraClient [15:11:17] WARN [HConnectionManager] : me.prettyprint.hector.api.exceptions.HectorTransportException: org.apache.thrift.transport.TTransportException: java.net.SocketException:   at > me.prettyprint.cassandra.connection.client.HThriftClient.getCassandra(HThriftClient.java:82)   at > me.prettyprint.cassandra.connection.HConnectionManager.operateWithFailover(HConnectionManager.java:236)   at > me.prettyprint.cassandra.model.ExecutingKeyspace.doExecuteOperation(ExecutingKeyspace.java:97)    me.prettyprint.cassandra.model.MutatorImpl.execute(MutatorImpl.java:243)    me.prettyprint.cassandra.model.MutatorImpl.insert(MutatorImpl.java:69)   at com.app.App.main(App.java:40) : org.apache.thrift.transport.TTransportException: java.net.SocketException:    org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:147)    org.apache.thrift.transport.TFramedTransport.flush(TFramedTransport.java:157)   at org.apache.cassandra.thrift.Cassandra $Client.send_set_keyspace (Cassandra.java:466)   at org.apache.cassandra.thrift.Cassandra $Client.set_keyspace (Cassandra.java:455)   at > me.prettyprint.cassandra.connection.client.HThriftClient.getCassandra(HThriftClient.java:78)   ... 5 : java.net.SocketException:    java.net.SocketOutputStream.socketWrite0 ( )    java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:109)    java.net.SocketOutputStream.write(SocketOutputStream.java:153)   at > org.apache.thrift.transport.TIOStreamTransport.write(TIOStreamTransport.java:145)   ... 9 [15:11:17] INFO [HConnectionManager] CassandraClient . . [15:11:17] INFO [HConnectionManager] CassandraClient . . [15:11:17] INFO [HConnectionManager] localhost (127.0.0.1): 9160

+3
1

-

conf.setRetryDownedHostsDelayInSeconds(5);

5 . , .

thrift_max_message_length_in_mb, ?

.

+2

More articles:


All Articles