hello i have an error which persist since 2 days org.apache.flink.table.api.ValidationException: Column types of query result and sink for 'null' do not match.
Cause: Incompatible types for sink column 'startTime' at position 2.
Query schema: [rideId: BIGINT NOT NULL, isStart: BOOLEAN NOT NULL, startTime: RAW('org.joda.time.DateTime', '...'), endTime: RAW('org.joda.time.DateTime', '...'), startLon: FLOAT NOT NULL, startLat: FLOAT NOT NULL, endLon: FLOAT NOT NULL, endLat: FLOAT NOT NULL, passengerCnt: SMALLINT NOT NULL, taxiId: BIGINT NOT NULL, driverId: BIGINT NOT NULL]
Sink schema: [rideId: BIGINT, isStart: BOOLEAN, startTime: RAW('org.joda.time.DateTime', ?), endTime: RAW('org.joda.time.DateTime', ?), startLon: FLOAT, startLat: FLOAT, endLon: FLOAT, endLat: FLOAT, passengerCnt: SMALLINT, taxiId: BIGINT, driverId: BIGINT]