Dheeraj Panangat
04/04/2023, 5:34 PMCaused by: java.lang.ClassCastException: class org.apache.flink.table.data.columnar.vector.heap.HeapBytesVector cannot be cast to class org.apache.flink.table.data.columnar.vector.LongColumnVector (org.apache.flink.table.data.columnar.vector.heap.HeapBytesVector and org.apache.flink.table.data.columnar.vector.LongColumnVector are in unnamed module of loader 'app')
at org.apache.flink.table.data.columnar.vector.VectorizedColumnBatch.getLong(VectorizedColumnBatch.java:88)
at org.apache.flink.table.data.columnar.ColumnarRowData.getLong(ColumnarRowData.java:107)
at org.apache.flink.table.data.RowData.lambda$createFieldGetter$245ca7d1$7(RowData.java:249)
at org.apache.flink.table.data.RowData.lambda$createFieldGetter$25774257$1(RowData.java:296)
at org.apache.flink.table.runtime.typeutils.RowDataSerializer.toBinaryRow(RowDataSerializer.java:207)
at org.apache.flink.table.runtime.typeutils.RowDataSerializer.serialize(RowDataSerializer.java:103)
at org.apache.flink.table.runtime.typeutils.RowDataSerializer.serialize(RowDataSerializer.java:48)
Martijn Visser
04/04/2023, 6:08 PM