Re: busy thread on IncomingStreamReader ?

2010-09-06 Thread Anty
loop to cause busy thread. From thread dump, >> it >> > looks like fc.transferFrom() in IncomingStreamReader never return: >> > >> > while (bytesRead < pendingFile.getExpectedBytes()) { >> > bytesRead += fc.transferFrom(socketChannel, bytesRead, >> > FileStreamTask.CHUNK_SIZE); >> > pendingFile.update(bytesRead); >> > } >> > >> > >> > On Tue, Apr 20, 2010 at 05:48, Rob Coli wrote: >> >> >> >> On 4/17/10 6:47 PM, Ingram Chen wrote: >> >>> >> >>> after upgrading jdk from 1.6.0_16 to 1.6.0_20, the problem solved. >> >> >> >> FYI, this sounds like it might be : >> >> >> >> https://issues.apache.org/jira/browse/CASSANDRA-896 >> >> >> >> >> http://bugs.sun.com/view_bug.do;jsessionid=60c39aa55d3666c0c84dd70eb826?bug_id=6805775 >> >> >> >> Where garbage collection issues in JVM/JDKs before 7.b70 leads to GC >> >> storming which hoses performance. >> >> >> >> =Rob >> > >> > >> > >> > >> > >> > > > > -- > Ingram Chen > online share order: http://dinbendon.net > blog: http://www.javaworld.com.tw/roller/page/ingramchen > -- Best Regards Anty Rao

Re: Question about hinted handoff

2010-07-08 Thread Anty
peration is failure. > > Correctly? > > Thanks. > > Shen > -- Best Regards Anty Rao

Re: Question about hinted handoff

2010-07-08 Thread Anty
Sorry I am wrong .Miss the CF=one. On Thu, Jul 8, 2010 at 5:27 PM, Anty wrote: > > > On Thu, Jul 8, 2010 at 4:11 PM, ChingShen wrote: > >> Hi all, >> >> Please consider this case: (RF=1, CL=ONE) >> >> 1. I have A, B and C nodes. >> 2. A nod

Re: Question about hinted handoff

2010-07-08 Thread Anty
hough the write operation is failure. > > Correctly? > > Thanks. > > Shen > -- Best Regards Anty Rao

Re: Why so many commitlogs ?

2010-07-08 Thread Anty
Hi:Jonathan I have found out what's going wrong. I change the configuration 1440 which prevent memtables of LocaitonInfo and HintsColumnFamily to flush if there are a few hint records writen to many commitlog segment. On Thu, Jul 8, 2010 at 9:43 AM, Anty wrote: > > > On Thu, Jul 8

Re: Why so many commitlogs ?

2010-07-07 Thread Anty
commitlog take so much time. > > On Wed, Jul 7, 2010 at 8:07 PM, Anty wrote: > > Thx Jonathan. > > > > > > On Wed, Jul 7, 2010 at 11:58 PM, Jonathan Ellis > wrote: > >> > >> number of memtables waiting to flush has a pretty low bound (# of data

Re: Why so many commitlogs ?

2010-07-07 Thread Anty
l 7, 2010 at 10:35 AM, Anty wrote: > > yes, i know. I only insert records into one CF. > > > > when a memtable flush complete, commitlog will check if there are some > > obsolete commitlog segments. > > I don't known why there are so many commitlog file out ther

Re: Why so many commitlogs ?

2010-07-07 Thread Anty
event many commitlog files from being removed. On Wed, Jul 7, 2010 at 10:13 PM, Jonathan Ellis wrote: > commitlogs can be removed after _all_ the CFs they have data for have > been flushed. > > On Wed, Jul 7, 2010 at 5:21 AM, Anty wrote: > > Hi:all > > In my little clu

Why so many commitlogs ?

2010-07-07 Thread Anty
Hi:all In my little cluter ,after i insert many many records into cassandra, there are hundreds of commit log files in commitlog log directory. is it normal ? I read the source code of commitlog , there shouldn't be so many commitlog log files . any clue will be appreciate. -- Best Regards

Re: GC Storm

2010-06-12 Thread Anty
THX for your reply ,Jonathan. On Sun, Jun 13, 2010 at 11:27 AM, Jonathan Ellis wrote: > On Sat, Jun 12, 2010 at 7:46 PM, Anty wrote: > > Hi:ALL > > I have 10 nodes cluster ,after inserting many records into the cluster, i > > compact each node by nodetool compact. > >

GC Storm

2010-06-12 Thread Anty
\ -Xmx14G \ standard What's wrong with it? Any suggestion will be appreciated. -- Best Regards Anty Rao

PhantomReference in Cassandra

2010-06-05 Thread Anty
lerate the GC process. try { r.cleanup(); r.clear(); } catch (IOException e) { logger.error("Error deleting " + r.path, e); } -- Best Regards Anty Rao

Re: About SStable Writer

2010-05-05 Thread Anty
THX schubert. On Thu, May 6, 2010 at 6:56 AM, Jonathan Ellis wrote: > Yes, this is a bug. Patch attached to > https://issues.apache.org/jira/browse/CASSANDRA-1056 > > On Wed, May 5, 2010 at 2:09 AM, Anty wrote: > > HI:All > > > > In source code of 0.6.1 ,in S

About SStable Writer

2010-05-05 Thread Anty
the values above two are different, is it a bug? -- Best Regards Anty Rao

Re: 0.5.1 exception: java.io.IOException: Reached an EOL or something bizzare occured

2010-04-03 Thread Anty
; >>> > /172.19.15.210 > >> >>> > BufferSizeRemaining: 16 > >> >>> > java.io.IOException: Reached an EOL or something bizzare occured. > >> >>> > Reading > >> >>> > from: /172.19.15.210 BufferSizeRemaining: 16 > >> >>> > at > >> >>> > org.apache.cassandra.net.io.StartState.doRead(StartState.java:44) > >> >>> > at > >> >>> > > >> >>> > > org.apache.cassandra.net.io.ProtocolState.read(ProtocolState.java:39) > >> >>> > at > >> >>> > org.apache.cassandra.net.io.TcpReader.read(TcpReader.java:95) > >> >>> > at > >> >>> > > >> >>> > > >> >>> > > org.apache.cassandra.net.TcpConnection$ReadWorkItem.run(TcpConnection.java:445) > >> >>> > at > >> >>> > > >> >>> > > >> >>> > > java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) > >> >>> > at > >> >>> > > >> >>> > > >> >>> > > java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) > >> >>> > at java.lang.Thread.run(Thread.java:636) > >> >>> > > >> >>> > INFO [MESSAGING-SERVICE-POOL:2] 2010-03-27 23:25:05,580 > >> >>> > TcpConnection.java > >> >>> > (line 315) Closing errored connection > >> >>> > java.nio.channels.SocketChannel[connected local=/ > 172.19.15.209:7000 > >> >>> > remote=/172.19.15.210:45504] > >> >>> > WARN [MESSAGING-SERVICE-POOL:1] 2010-03-27 23:25:05,632 > >> >>> > TcpConnection.java > >> >>> > (line 485) Exception was generated at : 03/27/2010 23:25:05 on > >> >>> > thread > >> >>> > MESSAGING-SERVICE-POOL:1 > >> >>> > > >> >> > >> > > >> > > > > > > -- Best Regards Anty Rao