运行cassandra和netflix.astyanax库时没有任何特定错误消息的Apache TransportException

问题描述

我正在尝试对Cassandra执行查询。 使用的端口是9160。 节俭服务器正在运行。通过使用以下命令。 ./nodetool enablethrift 使用Cassandra 3.0.9

Caused by: ! com.netflix.astyanax.connectionpool.exceptions.TransportException: TransportException: [host=127.0.0.1(127.0.0.1):9160,latency=23(23),attempts=1]org.apache.thrift.transport.TTransportException
! at com.netflix.astyanax.thrift.ThriftConverter.ToConnectionPoolException(ThriftConverter.java:197)
! at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:65)
! at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:28)
! at com.netflix.astyanax.thrift.ThriftSyncConnectionFactoryImpl$ThriftConnection.execute(ThriftSyncConnectionFactoryImpl.java:151)
! at com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:69)
! at com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:256)
! at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3.execute(AbstractThriftCqlQuery.java:80)
! at lithium.cassandra.dao.AbstractCassandraDao.executeQuery(AbstractCassandraDao.java:84)
!... 60 common frames omitted
Caused by: ! org.apache.thrift.transport.TTransportException: null
! 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_execute_prepared_cql3_query(Cassandra.java:1689)
! at org.apache.cassandra.thrift.Cassandra$Client.execute_prepared_cql3_query(Cassandra.java:1674)
! at com.netflix.astyanax.thrift.ThriftCql3Query.execute_prepared_cql_query(ThriftCql3Query.java:29)
! at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3$1.internalExecute(AbstractThriftCqlQuery.java:92)
! at com.netflix.astyanax.thrift.AbstractThriftCqlQuery$3$1.internalExecute(AbstractThriftCqlQuery.java:82)
! at com.netflix.astyanax.thrift.AbstractOperationImpl.execute(AbstractOperationImpl.java:60)
!... 66 common frames omitted```

解决方法

我遇到这个问题是因为我有几个线程，但是每个请求我必须处理的数据很大。 （作为一个请求的一部分需要处理 200000 个对象。每个对象都在排队。）一旦我减少了收到的对象数量，问题就解决了。