Flink半托管(基于ACK)产品需要您在线下完成作业开发后,再在Flink半托管(基于ACK)控制台上提交作业到集群上运行。

代码开发

您可以参见以下文档开发Flink半托管(基于ACK)产品业务代码:

限制说明

由于Flink半托管(基于ACK)产品受部署环境、网络环境等因素的影响,所以开发Flink半托管(基于ACK)作业,需要注意以下限制:
  • 目前仅支持开源Flink V1.10版本。
  • 目前仅支持JAR形式的作业提交和运行。
  • 目前仅支持运行单个JAR形式的作业。
  • 不支持在Main函数中读取本地配置。
  • Flink半托管(基于ACK)运行环境使用的是JDK1.8,请使用JDK1.8进行作业开发。