本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
作业迁移 原始集群计算说明:Flink 中的计算逻辑为:统计每 5分钟窗口内订单的订单总量和订单总金额。为便于介绍,以上计算逻辑在自建集群上分别使用三种 API(Datastream、Table/SQL、PyFlink)来实现。请先下载实现代码 https://github.com/RealtimeCompute/flink2vvp,说明如下:Datastream:参考 DataStreamJobKafka2Rds....