数据湖探索 DLI-使用Flink Jar读写DIS开发指南:环境准备

时间:2024-12-05 10:45:40

环境准备

  • 已在 DLI 控制台购买了通用队列。
  • 已购买了DIS通道。开通DIS通道
  • 用户在使用Flink 1.12版本,则依赖的Dis connector版本需要不低于2.0.1,详细代码参考DISFlinkConnector相关依赖,如何配置connector,详细参考自定义Flink Streaming作业

    若读取DIS,且配置groupId,则需要提前在DIS的“App管理”中创建所需的App名称。

  • 请勿将disToDis.properties放在生成的jar包中,在代码里有关于disToDis.properties的路径,如果放在jar包中,代码会找不到disToDis.properties路径。
support.huaweicloud.com/devg-dli/dli_09_0208.html