Flink半托管/ACK需要您在线下完成作业开发后,再在Flink半托管/ACK控制台上提交作业到集群上运行。
代码开发
您可以参见以下文档开发Flink半托管/ACK产品业务代码:
- Apache Flink是什么,以及它的体系架构、应用程序和特性功能等,请参见Apache Flink介绍。
- Apache Flink V1.10业务代码开发,请参见Flink DataStream API开发指南和Flink Table API & SQL开发指南。
- Apache Flink的编码、Java语言、Scala语言、组件和格式等指南,请参见代码风格和质量指南。
- Apache Flink编码过程中遇到的问题及解决方法,请参见常见问题。
限制说明
由于Flink半托管/ACK产品受部署环境、网络环境等因素的影响,所以开发Flink半托管/ACK作业,需要注意以下限制:
- 目前仅支持开源Flink V1.10版本。
- 目前仅支持JAR形式的作业提交和运行。
- 目前仅支持运行单个JAR形式的作业。
- 不支持在Main函数中读取本地配置。
- Flink半托管/ACK运行环境使用的是JDK1.8,请使用JDK1.8进行作业开发。
在文档使用中是否遇到以下问题
更多建议
匿名提交