hello i have an error which persist since 2 days o...
# random
m
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]
m
Please post only once to avoid overly creating notifications.
Any other comments you should leave in the thread
m
ok sorry my first share here