How to prevent OutOfMemory error

[richiesgr]

Hi
I'm trying to use the package to read standard mysql Binlog.
On my files from the server I always fails with OOM exception.
After profiling I get to this code

Event internalEvent = transactionPayloadEventDeserializer.nextEvent(destinationInputStream);
while(internalEvent != null) 
{
            decompressedEvents.add(internalEvent);
            internalEvent = transactionPayloadEventDeserializer.nextEvent(destinationInputStream);
  }

So there is these internal event (eventType=EXT_UPDATE_ROWS) and since I've these you continue to fill the decompressedEvents ArrayList ???!!
In my case seems there is thousands of these internal event so I always finishing by OOM.

So my question is there a way to prevent this behavior ?

Thanks