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