mincwang commented on issue #6550:
URL:
https://github.com/apache/incubator-doris/issues/6550#issuecomment-918741871
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.
```bash
Reason: Parse json data for JsonDoc failed. code = 2, error-info:The
document root must not be followed by other values..
```
--
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]
