在Mysql中有一张表,是触发器定时汇总数据后插入到这张表中;Flink DOris Connector没有同步Mysql表中的最新数据到Doris中.
Doris版本:2.0.4
flink-doris-connector版本:1.18-1.5.2
Mysql建表语句:
-- vehicle_network.cybertron_data_brain_snaps definition
引用
CREATE TABLEcybertron_data_brain_snaps(
idint(10) unsigned NOT NULL AUTO_INCREMENT,
park_codevarchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT '',
vehicle_vinvarchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT '',
date_timevarchar(50) CHARACTER SET utf8 COLLATE utf8_general_ci DEFAULT '',
takeover_countint(5) DEFAULT '0',
remote_odometerbigint(20) DEFAULT '0',
remote_durationbigint(20) DEFAULT '0',
auto_odometerbigint(20) DEFAULT '0',
auto_durationbigint(20) DEFAULT '0',
adas_request_countint(4) DEFAULT '0',
emergent_takeover_countint(4) DEFAULT '0',
pdu_durationbigint(20) DEFAULT NULL,
pdu_odometerbigint(20) DEFAULT NULL,
pdu_request_countint(11) DEFAULT NULL,
auto_error_intercept_countint(11) DEFAULT '0' COMMENT '自动驾驶异常跳出次数',
from_auto_pdu_request_countint(11) DEFAULT '0',
date_addtimestamp NULL DEFAULT CURRENT_TIMESTAMP,
park_namevarchar(32) DEFAULT NULL,
vin_idvarchar(16) DEFAULT NULL,
pdu_monitor_durationdouble DEFAULT NULL,
pdu_control_durationdouble DEFAULT NULL,
provincevarchar(16) DEFAULT NULL,
cityvarchar(16) DEFAULT NULL,
operate_stateint(11) DEFAULT NULL,
waring_cntint(11) DEFAULT '0',
simulate_odometerbigint(20) DEFAULT '0',
simulate_durationbigint(20) DEFAULT '0',
virtual_odometerbigint(20) DEFAULT '0',
PRIMARY KEY (id),
KEYcybertron_data_brain_snaps_date_time_index(date_time),
KEYcybertron_data_brain_snaps_vehicle_vin_date_time_index(vehicle_vin,date_time),
KEYcybertron_data_brain_snaps_vin_id_index(park_name,province,city,operate_state,vin_id)
) ENGINE=InnoDB AUTO_INCREMENT=591797 DEFAULT CHARSET=utf8;
插入数据脚本:
INSERT INTO vehicle_network.cybertron_data_brain_snaps (id, park_code, vehicle_vin, date_time, takeover_count, remote_odometer, remote_duration, auto_odometer, auto_duration, adas_request_count, emergent_takeover_count, pdu_duration, pdu_odometer, pdu_request_count, auto_error_intercept_count, from_auto_pdu_request_count, date_add, park_name, vin_id, pdu_monitor_duration, pdu_control_duration, province, city, operate_state, waring_cnt, simulate_odometer, simulate_duration, virtual_odometer) VALUES(1, '010000', '100038', '2020-05-20', 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, 0, '2020-12-09 13:14:50', '北京恒通商务园', NULL, NULL, NULL, NULL, NULL, NULL, 0, 0, 0, 0);