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
