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 > >
