Apache Flink

Hi All,
Is anyone familiar with this issue :
```Caused by: java.lang.ClassCastException: class org.apache.flink.table.data.vector.heap.HeapBytesVector cannot be cast to class org.apache.flink.table.data.vector.LongColumnVector (org.apache.flink.table.data.vector.heap.HeapBytesVector and org.apache.flink.table.data.vector.LongColumnVector are in unnamed module of loader 'app')
	at org.apache.flink.table.data.vector.VectorizedColumnBatch.getLong(VectorizedColumnBatch.java:86) ~[flink-table_2.12-1.14.6.jar:1.14.6]```
Getting this when executing

```tableEnv.createStatementSet()
                .addInsertSql("stmt1")
                .addInsertSql("stmt2")
                .addInsertSql("stmt3")
                .addInsertSql("stmt4")
                .execute();```


After upgrading Flink Version:
Getting
```2023-03-28 17:20:27,970 WARN  org.apache.flink.runtime.taskmanager.Task                    [] - Source: customer_profile[14] (3/20)#0 (c7520f27ea2dd5ea2f391468535ce981_3ba1d27b7fde4848a86e865c6c402dfa_2_0) switched from RUNNING to FAILED with failure cause: java.lang.NoClassDefFoundError: org/apache/flink/table/data/vector/ColumnVector```