本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
文档版本:20211222 35 开源 Flink迁移实时计算Flink全托管版 作业迁移 步骤2 修改源代码中的结果表为 rds_new_table3,避免冲突使用新的 kafka consumer group id(注意在 kafka控制台创建消费组)。步骤3 在 pom中移除 2.1.1步骤 3添加的依赖,参考如下。新:文档版本:20211222 36 开源 Flink迁移实时计算Flink全托管版 ...