本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
请先下载实现代码 https://github.com/RealtimeCompute/flink2vvp,说明如下:Datastream:参考 DataStreamJobKafka2Rds.java Table/SQL:参考 TableJobKafka2Rds.java PyFlink:参考 pyflinkjobkafka2rds_old.py(迁 移 前)和 pyflinkjobkafka2rds_new.py(迁移后)2.1.Table/SQL JAR迁移至 SQL 场景说明:本场景将自建 Flink ...