Hi,
I and Ruchir tried query using AllRowsReader recipe but had no luck. We are
seeing PoolTimeoutException.
SEVERE: [Thread_1] Error reading RowKeys
com.netflix.astyanax.connectionpool.exceptions.PoolTimeoutException:
PoolTimeoutException: [host=servername, latency=2003(2003), attempts=4]Timed
out waiting for connection
at
com.netflix.astyanax.connectionpool.impl.SimpleHostConnectionPool.waitForConnection(SimpleHostConnectionPool.java:231)
at
com.netflix.astyanax.connectionpool.impl.SimpleHostConnectionPool.borrowConnection(SimpleHostConnectionPool.java:198)
at
com.netflix.astyanax.connectionpool.impl.RoundRobinExecuteWithFailover.borrowConnection(RoundRobinExecuteWithFailover.java:84)
at
com.netflix.astyanax.connectionpool.impl.AbstractExecuteWithFailoverImpl.tryOperation(AbstractExecuteWithFailoverImpl.java:117)
at
com.netflix.astyanax.connectionpool.impl.AbstractHostPartitionConnectionPool.executeWithFailover(AbstractHostPartitionConnectionPool.java:338)
at
com.netflix.astyanax.thrift.ThriftColumnFamilyQueryImpl$2.execute(ThriftColumnFamilyQueryImpl.java:397)
at
com.netflix.astyanax.recipes.reader.AllRowsReader$1.call(AllRowsReader.java:447)
at
com.netflix.astyanax.recipes.reader.AllRowsReader$1.call(AllRowsReader.java:419)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
at java.lang.Thread.run(Thread.java:745)
We did receive a portion of data which changes on every try. We used following
method.
boolean result = new AllRowsReader.Builder<String, String>(keyspace,
CF_STANDARD1)
.withColumnRange(null, null, false, 0)
.withPartitioner(null) // this will use keyspace's partitioner
.forEachRow(new Function<Row<String, String>, Boolean>() {
@Override
public Boolean apply(@Nullable Row<String, String> row) {
// Process the row here ...
return true;
}
})
.build()
.call();
Tried setting concurrency level as mentioned in this post
(https://github.com/Netflix/astyanax/issues/411) as well on both astyanax
1.56.49 and 2.0.0. Still nothing.
