本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
文档版本:20211222 12 开源 Flink迁移实时计算Flink全托管版 基础环境搭建 步骤2 在 Flink SQL中添加以下作业,注意修改 properties.bootstrap.servers为前面创建 的 kafka的接入点。CREATE TEMPORARY TABLE data_in(id VARCHAR,order_value FLOAT)WITH('connector'='datagen','rows-per-second'='100','fields.id.length'...