本文将分别从Table/SQL JAR迁移至SQL、Datastream JAR迁移和Table/SQL JAR迁移至JAR三方面，为您介绍如何进行自建Flink作业迁移。

背景信息

本文以统计每5分钟窗口内订单的订单总量和订单总金额的计算逻辑为例，为您介绍如何进行自建Flink作业迁移。为便于介绍，在自建集群上将分别使用Datastream和Table/SQL两种Demo来实现以上计算逻辑。

为了快速进行三种场景的自建Flink作业迁移过程，您需要提前进行以下操作：
  • 下载代码示例
    请单击代码示例下载实现代码。下载文件说明如下：
    • Table/SQL类型：TableJobKafka2Rds.java
    • Datastream类型：DataStreamJobKafka2Rds.java
  • 搭建基础环境
    为了快速跟您展示作业迁移过程，我们利用云速搭CADT产品，来搭建一个基础迁移环境，来演示三种场景的自建Flink作业迁移过程。基础环境搭建过程，请参见搭建基础环境。
    说明 如果您是自建的Flink集群，可以直接使用自建的环境进行迁移，无需搭建基础环境。

相关文档