Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-25 Thread Sourabh Chandak
gt;>> >>> >>> On Thu, Sep 24, 2015 at 3:51 PM, Sourabh Chandak >> > wrote: >>> >>>> Adding Cody and Sriharsha >>>> >>>> On Thu, Sep 24, 2015 at 1:25 PM, Sourabh Chandak >>> > wrote: >>>> >&g

Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-25 Thread Cody Koeninger
>> >>> Adding Cody and Sriharsha >>> >>> On Thu, Sep 24, 2015 at 1:25 PM, Sourabh Chandak >>> wrote: >>> >>>> Hi, >>>> >>>> I have ported receiver less spark streaming for kafka to Spark 1.2 and >&g

Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-24 Thread Sourabh Chandak
t;>> wrote: >>> >>>> Hi, >>>> >>>> I have ported receiver less spark streaming for kafka to Spark 1.2 and >>>> am trying to run a spark streaming job to consume data form my broker, but >>>>

Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-24 Thread Sourabh Chandak
>>> I have ported receiver less spark streaming for kafka to Spark 1.2 and >>> am trying to run a spark streaming job to consume data form my broker, but >>> I am getting the following error: >>> >>> 15/09/24 20:17:45 ERROR BoundedByteBuffe

Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-24 Thread Cody Koeninger
y broker, but I >> am getting the following error: >> >> 15/09/24 20:17:45 ERROR BoundedByteBufferReceive: OOME with size 352518400 >> java.lang.OutOfMemoryError: Java heap space >> at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57

Re: ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-24 Thread Sourabh Chandak
; > 15/09/24 20:17:45 ERROR BoundedByteBufferReceive: OOME with size 352518400 > java.lang.OutOfMemoryError: Java heap space > at java.nio.HeapByteBuffer.(HeapByteBuffer.java:57) > at java.nio.ByteBuffer.allocate(Byt

ERROR BoundedByteBufferReceive: OOME with size 352518400

2015-09-24 Thread Sourabh Chandak
Hi, I have ported receiver less spark streaming for kafka to Spark 1.2 and am trying to run a spark streaming job to consume data form my broker, but I am getting the following error: 15/09/24 20:17:45 ERROR BoundedByteBufferReceive: OOME with size 352518400 java.lang.OutOfMemoryError: Java heap