本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
为便于介绍,以上计算逻辑在自建集群上分别使用三种 API(Datastream、Table/SQL、PyFlink)来实现。请先下载实现代码 https://github.com/RealtimeCompute/flink2vvp,说明如下:Datastream:参考 DataStreamJobKafka2Rds.java Table/SQL:参考 TableJobKafka2Rds.java PyFlink:参考 pyflinkjobkafka2rds_old.py(迁 移 前)和...