FlinkSQL链接Doris无法写入数据(未见报错)

Viewed 47

通过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'
);

这是连接信息

1 Answers

贴一下taskmanager日志