tidb 使用flink-sql-connector同步时,大表不能成功同步

是不是数据格式不对导致的,

2022-08-18 11:19:34,333 WARN org.apache.flink.runtime.taskmanager.Task [] - Source: cnft_item_backup[1] (1/1)ClassCastException: java.lang.Integer cannot be cast to java.lang.Long when using oracle connector #121 (c40c3c7e9651b3343fa3c8f33eadd159) switched from RUNNING to FAILED with failure cause: org.tikv.common.exception.TiClientInternalException: Error scanning data from region.

日志上描述的类型转换错误呢