[GitHub] [incubator-doris] mincwang edited a comment on issue #6550: doris-flink-connecter数据换行配置不起作用

[GitBox <gi...@apache.org>]

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.
   
   
   ```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: commits-unsubscribe@doris.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org