Here is my test program: public class CClient
{ public static void main(String[] args) throws TException, InvalidRequestException, UnavailableException, UnsupportedEncodingException, NotFoundException { TTransport tr = new TSocket("localhost", 9160); TProtocol proto = new TBinaryProtocol(tr); Cassandra.Client client = new Cassandra.Client(proto); tr.open(); int count = 0; int block = 1000; String key = " "; while (true) { List<String> list = client.get_key_range("Keyspace1", "Standard1", key, "~", block, ConsistencyLevel.ONE); int size = list.size(); if (size == 0) break; count += size; key = list.get(size - 1) + '~'; System.out.println("Count: " + Integer.toString(count)); } tr.close(); } } Jonathan Ellis wrote: > what operations are you doing? > > On Fri, Nov 13, 2009 at 1:15 PM, elsif <elsif.t...@gmail.com> wrote: > >> I did some more testing on this. The file descriptor leaks do not occur >> on a single node configuration under 0.4.2 or trunk. >> >> The leaks do occur when you have at least two nodes. I was able to >> reproduce this with just 220,000 keys on both 0.4.2 and trunk. >> >> >> >> > >