??????Flink mysql cdc to doris??schema join ????????doris????????

[di wu]

Hi, thanks for your question.
1. I tested it, and flink cdc imports the doris aggregation model. In the case 
of join and groupby, data can be written and updated normally.
2. The flink-doris-connector version 1.0.3 is based on batch-based streamload, 
which is controlled by parameters such as sink.batch.size.



Thanks && Regards,
di.wu

------------------ ???????? ------------------
??????:                                                                         
                                               "dev"                            
                                                        
<joshxi...@outlook.com&gt;;
????????:&nbsp;2022??5??27??(??????) ????10:34
??????:&nbsp;"dev@doris.apache.org"<dev@doris.apache.org&gt;;

????:&nbsp;Flink mysql cdc to doris??schema join ????????doris????????



??????:
&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ??????????mysql flink cdc to doris??, 
??????????,&nbsp; ??flink??schema????join, group by????????????????, doris 
flink connector??????????????doris????????, 
????????????(sum)??????????.(flink1.13.6 doris1.0.0 rc03, connector??????????)
??????????????????, ??flink??????schema join group 
by????????????(flink??????20??????????), flink??????????, ????????, 
????update_time??????????, update_count????????sum????, 
insert??????????96????????????????mo_num????????.
Doris ??????????:
{

tenant_code AGGREGATE KEY,

mo_num REPLACE,

update_time MAX,

update_count SUM default 1
}
????????:
code
mo_num
xxxx
update_time
update_count
000032
123
????????????
2022-05-19 19:00:28
96


????:

1.&nbsp;&nbsp;&nbsp;&nbsp; ????????????????? ????????????????????????????, 
??????????????, ????????????????????sum???????????

2.&nbsp;&nbsp;&nbsp;&nbsp; ????????????????, ????????? 
?????????????????????????????????????????