[GitHub] [incubator-doris] xhmz removed a comment on issue #6624: doris flink connector do not support flink 1.13 [Bug]

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

xhmz removed a comment on issue #6624:
URL: https://github.com/apache/incubator-doris/issues/6624#issuecomment-918724192


   --CREATE TABLE random_source (
    --   id INT,
    --   f_random_str VARCHAR
    -- ) WITH ( 
    -- 'connector' = 'datagen', 
    -- 'rows-per-second'='2',               -- 每秒产生的数据条数
    -- 'fields.id.kind'='sequence',   -- 有界序列（结束后自动停止输出）
    -- 'fields.id.start'='1',         -- 序列的起始值
    -- 'fields.id.end'='10000',       -- 序列的终止值
    -- 'fields.f_random_str.length'='100'      -- 随机字符串的长度
   --);
   CREATE TABLE flink_doris_source (
       id INT,
       f_random_str VARCHAR
       ) 
       WITH (
         'connector' = 'doris',                    -- 固定值 'doris'
         'fenodes' = 'xxx',          -- Doris FE http 地址
         'table.identifier' = 'test.xxx',  -- Doris 表名 格式：db1.tbl1
         'username' = 'xxx',                      -- 访问Doris的用户名
         'password' = 'xxx'                 -- 访问Doris的密码
         --'sink.batch.size' = '500',                -- 单次写BE的最大行数
        -- 'sink.batch.interval' = '1s'              -- flush 间隔时间，超过该时间后异步线程将 缓存中数据写入BE。 默认值为1秒，支持时间单位ms、s、min、h和d。设置为0表示关闭定期写入。
   );
   INSERT INTO flink_doris_source select id, f_random_str from source;
   
   > can you show your flinksql ?
   
   


-- 
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