??????????????????????????????????
????flink-1.14.0????????????chk(500ms??????)????????????????????????
source??kafka??-> (1min??window????????????????count????) -> sink(mysql)
??????????????kafka????????????????????1??????????????????????kafka????????????????
??????sink??????????????kafka??????????????????????chk????????????

??????sink????????????????????????????

回复