Re: Modifying Cassandra's threadpool queues

2016-01-13 Thread Benedict Elliott Smith
The SEPWorker manages its own count of available items that have been enqueued (but not yet dequeued), so it dequeues knowing there should be an item available; if there is not, your queue is swallowing them, either temporarily or permanently. So, in all likelihood (as you suggest), you simply hav

Modifying Cassandra's threadpool queues

2016-01-13 Thread Waleed Reda
0down votefavorite I've been meddling with Cassandra's (v 2.2.4) threadpool executors (namely SEPExecutor.java module) and trying to change the queues used for storing pending reads (that have no imm