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
