Hi ~,
??????Flink 1.9 SQL????????????????????????????????????Join??TopN??Distinct????????????????????????Operator??State???????????????????????????????????? 1. ????SQL??Table API??????????uid????uidhash??????????Kafka DataStreamSource??????uid????uidhash???????? 2. ????????Graph??????????SQL Job ??????GroupAggregator Operator????State??????????WebUI????????uidhash????SavePoint API??????????uid??????uidhash???????????????????????? 3. ??????????????????????????Union/Join????????Hive???? =?? ????????Finished Task ????????Job??????checkpoint?????????????????????????????????? ??????????
