Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 86360 invoked from network); 16 Dec 2010 17:45:44 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 16 Dec 2010 17:45:44 -0000 Received: (qmail 47386 invoked by uid 500); 16 Dec 2010 17:45:42 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 47280 invoked by uid 500); 16 Dec 2010 17:45:42 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 47272 invoked by uid 99); 16 Dec 2010 17:45:42 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 16 Dec 2010 17:45:42 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=RCVD_IN_DNSWL_LOW,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (nike.apache.org: local policy) Received: from [209.85.212.44] (HELO mail-vw0-f44.google.com) (209.85.212.44) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 16 Dec 2010 17:45:35 +0000 Received: by vws7 with SMTP id 7so1465467vws.31 for ; Thu, 16 Dec 2010 09:45:14 -0800 (PST) MIME-Version: 1.0 Received: by 10.229.212.4 with SMTP id gq4mr1911856qcb.185.1292521513397; Thu, 16 Dec 2010 09:45:13 -0800 (PST) Received: by 10.229.63.69 with HTTP; Thu, 16 Dec 2010 09:45:13 -0800 (PST) X-Originating-IP: [76.253.75.188] In-Reply-To: References: Date: Thu, 16 Dec 2010 11:45:13 -0600 Message-ID: Subject: Re: Too many open files Exception + java.lang.ArithmeticException: / by zero From: Nate McCall To: user@cassandra.apache.org Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable X-Virus-Checked: Checked by ClamAV on apache.org You probably want to switch to using mutator#addInsertion for some number of iterations (start with 1000 and adjust as needed), then calling execute(). This will be much more efficient. On Thu, Dec 16, 2010 at 11:39 AM, Amin Sakka, Novapost wrote: > > I'm using a unique client instance (using Hector) and a unique connection= to > cassandra. > For each insertion I'm using a new mutator and then I release it. > I have 473 =A0sstable "Data.db", the average size of each is 30Mo. > > > > 2010/12/16 Ryan King >> >> Are you creating a new connection for each row you insert (and if so >> are you closing it)? >> >> -ryan >> >> On Wed, Dec 15, 2010 at 8:13 AM, Amin Sakka, Novapost >> wrote: >> > Hello, >> > I'm using cassandra 0.7.0 rc1, a single node configuration, replicatio= n >> > factor 1, random partitioner, 2 GO heap size. >> > I ran my hector client to insert 5.000.000 rows but after a couple of >> > hours, >> > the following Exception occurs : >> > >> > =A0WARN [main] 2010-12-15 16:38:53,335 CustomTThreadPoolServer.java (l= ine >> > 104) >> > Transport error occurred during acceptance of message. >> > org.apache.thrift.transport.TTransportException: >> > java.net.SocketException: >> > Too many open files >> > at >> > >> > org.apache.thrift.transport.TServerSocket.acceptImpl(TServerSocket.jav= a:124) >> > at >> > >> > org.apache.cassandra.thrift.TCustomServerSocket.acceptImpl(TCustomServ= erSocket.java:67) >> > at >> > >> > org.apache.cassandra.thrift.TCustomServerSocket.acceptImpl(TCustomServ= erSocket.java:38) >> > at >> > >> > org.apache.thrift.transport.TServerTransport.accept(TServerTransport.j= ava:31) >> > at >> > >> > org.apache.cassandra.thrift.CustomTThreadPoolServer.serve(CustomTThrea= dPoolServer.java:98) >> > at >> > >> > org.apache.cassandra.thrift.CassandraDaemon.start(CassandraDaemon.java= :120) >> > at >> > >> > org.apache.cassandra.service.AbstractCassandraDaemon.activate(Abstract= CassandraDaemon.java:229) >> > at >> > >> > org.apache.cassandra.thrift.CassandraDaemon.main(CassandraDaemon.java:= 134) >> > Caused by: java.net.SocketException: Too many open files >> > at java.net.PlainSocketImpl.socketAccept(Native Method) >> > at java.net.PlainSocketImpl.accept(PlainSocketImpl.java:384) >> > at java.net.ServerSocket.implAccept(ServerSocket.java:453) >> > at java.net.ServerSocket.accept(ServerSocket.java:421) >> > at >> > >> > org.apache.thrift.transport.TServerSocket.acceptImpl(TServerSocket.jav= a:119) >> > >> > When I try to restart Cassandra, I have the following exception : >> > >> > ERROR 16:42:26,573 Exception encountered during startup. >> > java.lang.ArithmeticException: / by zero >> > at >> > >> > org.apache.cassandra.io.sstable.SSTable.estimateRowsFromIndex(SSTable.= java:233) >> > at >> > >> > org.apache.cassandra.io.sstable.SSTableReader.load(SSTableReader.java:= 284) >> > at >> > >> > org.apache.cassandra.io.sstable.SSTableReader.open(SSTableReader.java:= 200) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.(ColumnFamilyStore.jav= a:225) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore(Colu= mnFamilyStore.java:449) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.addIndex(ColumnFamilyStore.j= ava:306) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.(ColumnFamilyStore.jav= a:246) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore(Colu= mnFamilyStore.java:449) >> > at >> > >> > org.apache.cassandra.db.ColumnFamilyStore.createColumnFamilyStore(Colu= mnFamilyStore.java:437) >> > at org.apache.cassandra.db.Table.initCf(Table.java:341) >> > at org.apache.cassandra.db.Table.(Table.java:283) >> > at org.apache.cassandra.db.Table.open(Table.java:114) >> > at >> > >> > org.apache.cassandra.service.AbstractCassandraDaemon.setup(AbstractCas= sandraDaemon.java:138) >> > at >> > >> > org.apache.cassandra.thrift.CassandraDaemon.setup(CassandraDaemon.java= :55) >> > at >> > >> > org.apache.cassandra.service.AbstractCassandraDaemon.activate(Abstract= CassandraDaemon.java:216) >> > at >> > >> > org.apache.cassandra.thrift.CassandraDaemon.main(CassandraDaemon.java:= 134) >> > >> > I am looking for advice on how to debug this. >> > >> > Thanks, >> > -- >> > >> > Amin >> > >> > >> > >> > >> > > > > > -- > Amin > > > >