mincwang edited a comment on issue #6550:
URL:
https://github.com/apache/incubator-doris/issues/6550#issuecomment-918741871
@JNSimba thanks for your reply. here is my code, and some errors.
doris ddl：
```sql
CREATE TABLE `product` (
`id` int(11) NULL COMMENT "",
...
`gmt_modified` datetime NULL COMMENT "",
`gmt_create` datetime NULL COMMENT ""
) ENGINE=OLAP
DUPLICATE KEY(`id`, `id_hash`)
COMMENT "OLAP"
DISTRIBUTED BY HASH(`id`) BUCKETS 10
PROPERTIES (
"replication_num" = "3",
"in_memory" = "false",
"storage_format" = "V2"
);
```
flink sql doris-sink ddl：
```sql
CREATE TABLE product (
id INT,
...
gmt_modified TIMESTAMP(6),
gmt_create TIMESTAMP(6) )
WITH (
'connector' = 'doris',
'fenodes' = 'n3:8031',
'table.identifier' = 'dev.product',
'username' = 'root',
'sink.batch.size' = '100',
'sink.properties.column_separator' = '\x01',
'sink.properties.line_delimiter' = '\x02',
'sink.batch.interval' = '2s' ,
'password' = 'doris'
);
```
```sql
# flink insert sql
insert into product
select * from product_cdc_table ;
```
When we write data to dorsi by flink streaming, have following error occurs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
