本方案介绍如何将自建开源Flink集群的流式任务(包含Datastream、Table/SQL、PyFlink任务)迁移至阿里云实时计算全托管版。
id varchar,order_time timestamp(3),order_type varchar,order_value float,WATERMARK FOR order_time AS order_time-INTERVAL '2' SECOND)WITH('connector'='kafka','topic'='kafka-order','properties.bootstrap.servers'='192.168.0.76:9092,192.168.0.75:9092,192.168.0.74:9092','properties.group.id'='demo-group_...