组件版本信息

Doris数据

表结构信息

create table test(
	`id` varchar(20) NOT NULL,
	`data_time` datetime null
)ENGINE=OLAP
UNIQUE KEY(`id`)
DISTRIBUTED BY HASH(`id`) BUCKETS 1
PROPERTIES (
"replication_allocation" = "tag.location.default: 1"
);

flink 任务

create table doris_test(
	`id` varchar(20),
	`data_time` TIMESTAMP,
	PRIMARY KEY(`id`) NOT ENFORCED
)with(
	'connector' = 'doris',
	'fenodes' = 'localhost:8031',
	'table.identifier' = 'dim.test',
	'username' = 'root',
	'password' = '123456'
);
create table print(
	id varchar(20),
	data_time timestamp
)with(
	'connector' = 'print'
);
insert into print 
select * from doris_test;

结果

1978-01-12T05:29:45.600