Accumulo version 1.5.1 Storm 0.8.2
On Tue, Jun 24, 2014 at 10:53 PM, Sean Busbey <[email protected]> wrote: > Hi Sivan! > > Could you give us some additional details? > > What version of Accumulo? > > What version of Storm? > > It looks like this failure is happening within the Accumulo client that > you're running within Storm, is that correct? > > > > > On Tue, Jun 24, 2014 at 12:18 PM, Sivan Sasidharan <[email protected]> > wrote: > >> Accumulo fails with the below error when running in the storm cluster. >> Please advice. >> >> java.lang.OutOfMemoryError: unable to create new native thread >> at java.lang.Thread.start0(Native Method) >> at java.lang.Thread.start(Thread.java:640) >> at >> java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(ThreadPoolExecutor.java:703) >> at >> java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:652) >> at >> java.util.concurrent.AbstractExecutorService.submit(AbstractExecutorService.java:78) >> at >> org.apache.accumulo.core.client.impl.TabletServerBatchWriter$MutationWriter.addMutations(TabletServerBatchWriter.java:740) >> at >> org.apache.accumulo.core.client.impl.TabletServerBatchWriter$MutationWriter.addMutations(TabletServerBatchWriter.java:702) >> at >> org.apache.accumulo.core.client.impl.TabletServerBatchWriter.startProcessing(TabletServerBatchWriter.java:232) >> at >> org.apache.accumulo.core.client.impl.TabletServerBatchWriter.flush(TabletServerBatchWriter.java:320) >> at >> org.apache.accumulo.core.client.impl.BatchWriterImpl.flush(BatchWriterImpl.java:57) >> at >> com.ey.analytics.aap.realtime.core.bolts.adapters.RealTimeAccumuloTweetBolt.dataManipulate(RealTimeAccumuloTweetBolt.java:105) >> at >> com.ey.analytics.aap.realtime.core.bolts.RealTimeBolt.execute(RealTimeBolt.java:59) >> at >> backtype.storm.daemon.executor$fn__4050$tuple_action_fn__4052.invoke(executor.clj:566) >> at >> backtype.storm.daemon.executor$mk_task_receiver$fn__3976.invoke(executor.clj:345) >> at >> backtype.storm.disruptor$clojure_handler$reify__1606.onEvent(disruptor.clj:43) >> at >> backtype.storm.utils.DisruptorQueue.consumeBatchToCursor(DisruptorQueue.java:84) >> at >> backtype.storm.utils.DisruptorQueue.consumeBatchWhenAvailable(DisruptorQueue.java:58) >> at >> backtype.storm.disruptor$consume_batch_when_available.invoke(disruptor.clj:62) >> at >> backtype.storm.daemon.executor$fn__4050$fn__4059$fn__4106.invoke(executor.clj:658) >> at backtype.storm.util$async_loop$fn__465.invoke(util.clj:377) >> at clojure.lang.AFn.run(AFn.java:24) >> at java.lang.Thread.run(Thread.java:662) >> >> >> Thanks >> Sivan Sasidaran >> >> > > > -- > Sean >
