accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sean Busbey <bus...@cloudera.com>
Subject Re: Out Of Memory Error - Accumulo & Storm
Date Tue, 24 Jun 2014 17:23:59 GMT
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 <sivans82@gmail.com>
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

Mime
View raw message