Hi Jonathan,

It would be better if you describe your scenario along with the code. It
would be easier for the community to help.

On Tue, 15 Feb 2022, 23:33 Jonathan Weaver, <myordinat...@gmail.com> wrote:

> I'm getting the following exception running locally from my IDE (IntelliJ)
> but seems to not occur
> when running on a cluster. I'm assuming it may be related to memory
> settings on the runtime (machine has 64GB of ram avail) but not sure what
> setting to try and change.
>
> Caused by: java.lang.IndexOutOfBoundsException: offset=0,
> targetOffset=3568, numBytes=40, address=16, targetAddress=16
> at
> org.apache.flink.core.memory.MemorySegment.copyTo(MemorySegment.java:1441)
> at
> org.apache.flink.table.data.writer.AbstractBinaryWriter.writeSegmentsToVarLenPart(AbstractBinaryWriter.java:249)
> at
> org.apache.flink.table.data.writer.AbstractBinaryWriter.writeArray(AbstractBinaryWriter.java:110)
> at
> org.apache.flink.table.data.writer.BinaryArrayWriter.writeArray(BinaryArrayWriter.java:30)
> at
> org.apache.flink.table.data.writer.BinaryWriter.write(BinaryWriter.java:147)
> at
> org.apache.flink.table.runtime.typeutils.MapDataSerializer.toBinaryMap(MapDataSerializer.java:175)
> at
> org.apache.flink.table.runtime.typeutils.MapDataSerializer.copy(MapDataSerializer.java:109)
> at TableCalcMapFunction$148.flatMap_split18(Unknown Source)
> at TableCalcMapFunction$148.flatMap(Unknown Source)
> at
> org.apache.flink.table.runtime.operators.join.lookup.AsyncLookupJoinWithCalcRunner$TemporalTableCalcResultFuture.complete(AsyncLookupJoinWithCalcRunner.java:119)
>
> Was wondering if anyone had any insights or pointers on what could be
> causing that?
>
> Thanks!
> Jonathan
>
>

Reply via email to