通过FLinksql的client端,使用connector链接doris,使用inserrt into 语句往Doris的表中插入数据,任务执行成功,单插入的数据条数是0,库中也没数据。
经检查,确认Doris连接时没问题的,在client中可以通过select语句查询到Doris的表的数据,表的所有字段类型均为Varchar(2000)
create table sink_new_energy(
`vin` STRING,
`gpsTimeStamp` STRING,
`longAndlattude` STRING,
`averVehSpd` STRING,
`milestone` STRING,
`driveTime` STRING,
`driveDistance` STRING,
`eleConsumVol` STRING,
`eleFlushVol` STRING,
`eleFlushTime` STRING,
`socStart` STRING,
`socEnd` STRING,
`suddenUpSpdTimes` STRING,
`suddenDownSpdTimes` STRING,
`suddenTurnTimes` STRING,
`endWindowTime` STRING,
`sendTime` STRING,
`chuz_saic_new_energykey` STRING
)WITH (
'connector' = 'doris',
'fenodes' = '192.168.0.222:18030,192.168.0.333:18030,192.168.0.444:18030',
'table.identifier' = 'dmp_dw.new_energy',
'username' = 'root',
'password' = '123456',
'sink.enable-delete' = 'true',
'sink.label-prefix' = '202404161058'
);
这是连接信息