本文为您介绍Flink全托管DataStream API开发的限制说明和开发方法。
使用限制
由于Flink全托管产品受部署环境、网络环境等因素的影响，所以开发Flink全托管DataStream作业，需要注意以下限制：
- 仅支持JAR形式的作业提交和运行。
- 支持一个主JAR包和多个附加依赖JAR包。
- 不支持在Main函数中读取本地配置。
- Flink全托管产品开发界面上配置的参数优先级均低于作业代码中的优先级。为了保证作业的正常运行，建议优先在开发界面配置Checkpoint相关参数，请勿在作业代码中配置Checkpoint相关参数。
- 产品运行环境使用的是JDK 1.8，作业开发也需要使用JDK 1.8。
- 支持开源Scala V2.11版本。
注意事项
为了避免JAR包依赖冲突，您需要注意以下几点：
- 作业开发页面选择的Flink版本，请和Pom依赖中的Flink版本保持一致。
- Flink相关依赖，scope请使用provided，即在依赖中添加
<scope>provided</scope>。 - 其他第三方依赖请采用Shade方式打包，Shade打包详情请参见Apache Maven Shade Plugin。
Flink 依赖冲突问题，详情请参见如何解决Flink依赖冲突问题？
作业开发
您需要在线下完成作业开发后，再在Flink全托管开发控制台上提交作业到集群上运行。您在编写Flink全托管产品业务代码时，可以参见以下文档：
- Flink Datastream Connector依赖，请参见Connector依赖。
- Connector的使用方法，请参见Connector使用。
- Apache Flink简介，以及它的体系架构、应用程序和特性功能等，请参见Apache Flink介绍。
- Apache Flink V1.10业务代码开发，请参见Flink DataStream API开发指南和Flink Table API & SQL开发指南。
- Apache Flink的编码、Java语言、Scala语言、组件和格式等指南，请参见代码风格和质量指南。
- Apache Flink编码过程中遇到的问题及解决方法，请参见常见问题。
Connector使用
Maven中央库中已经放置了VVR Connector，以供您在作业开发时直接使用。您可以使用以下任意一种方式来使用Connector：
- （推荐）直接将Connector作为项目依赖打进作业JAR包。
- 在Maven项目的pom.xml文件中添加以下配置以引用SNAPSHOT仓库。
<repositories> <repository> <id>oss.sonatype.org-snapshot</id> <name>OSS Sonatype Snapshot Repository</name> <url>http://oss.sonatype.org/content/repositories/snapshots</url> <releases> <enabled>false</enabled> </releases> <snapshots> <enabled>true</enabled> </snapshots> </repository> <repository> <id>apache.snapshots</id> <name>Apache Development Snapshot Repository</name> <url>https://repository.apache.org/content/repositories/snapshots/</url> <releases> <enabled>false</enabled> </releases> <snapshots> <enabled>true</enabled> </snapshots> </repository> </repositories> - 检查您的settings.xml配置文件中是否存在
<mirrorOf>*</mirrorOf>配置。如果存在
<mirrorOf>*</mirrorOf>配置，则需要将此配置改为<mirrorOf>*,!oss.sonatype.org-snapshot,!apache.snapshots</mirrorOf>。修改的目的是为了避免SNAPSHOT仓库被覆盖，因为mirrorOf中只使用星号（*）会导致第一步中配置的两个repository被覆盖。 - 在作业的Maven POM文件中添加您需要的Connector作为项目依赖，示例如下。
<dependencies> <dependency> <groupId>com.alibaba.ververica</groupId> <artifactId>${connector.type}</artifactId> <version>${connector.version}</version> </dependency> </dependencies>每个Connector版本对应的Connector类型可能不同，建议您使用最新版本。Connector版本、VVR/Flink版本和Connector类型的对应关系请参见Connector列表。注意- 您需要在SNAPSHOT仓库（oss.sonatype.org）查找带SNAPSHOT的Connector版本， 在Maven中央库（search.maven.org）上会查找不到。
- 在使用多个Connector时，请注意META-INF目录需要Merge，即在pom.xml文件中添加如下代码。
<transformers> <!-- The service transformer is needed to merge META-INF/services files --> <transformer implementation="org.apache.maven.plugins.shade.resource.ServicesResourceTransformer"/> <transformer implementation="org.apache.maven.plugins.shade.resource.ApacheNoticeResourceTransformer"> <projectName>Apache Flink</projectName> <encoding>UTF-8</encoding> </transformer> </transformers>
- 在Maven项目的pom.xml文件中添加以下配置以引用SNAPSHOT仓库。
- 上传Connector JAR包到Flink全托管开发控制台后，填写配置信息。
- 登录实时计算管理控制台。
- 在Flink全托管页签，单击目标工作空间操作列下的控制台。
- 在左侧导航栏，单击资源上传。
- 单击上传资源，选择您要上传的目标Connector的JAR包。
您可以上传您自己开发的Connector，也可以上传Flink全托管产品提供的Connector。Flink全托管产品提供的Connector官方JAR包的下载地址，请参见Connector列表。
- 在目标作业开发页面附加依赖文件项，选择目标Connector的JAR包。
Connector列表
| Connector版本 | VVR/Flink版本 | Connector类型 |
|---|---|---|
| 1.13-vvr-4.0.7 | VVR 4.0.7（对应Flink 1.13） |
|
| 1.12-vvr-3.0.2-SNAPSHOT | VVR 3.0.2（对应Flink 1.12.3） |
|
| 1.11-vvr-2.1.3-SNAPSHOT | VVR 2.1.3（对应Flink 1.11.3） |
|
| 1.11-vvr-2.1.2-SNAPSHOT | VVR 2.1.2（对应Flink 1.11.2） |
|