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 <[email protected]> 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.
>>
>>
>>
>>
>
>
