基于Flink 1.12
Activity