accumulo-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Sivan Sasidharan <sivan...@gmail.com>
Subject Re: Out Of Memory Error - Accumulo & Storm
Date Tue, 24 Jun 2014 17:27:18 GMT
Accumulo version 1.5.1
Storm 0.8.2



On Tue, Jun 24, 2014 at 10:53 PM, Sean Busbey <busbey@cloudera.com> 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 <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