数据湖探索 DLI-使用Flink Jar读写DIS开发指南:常见问题

时间：2024-06-20 11:23:09

数据湖探索 DLI Flink Jar作业开发指南

常见问题

Q：作业运行失败，运行日志中有如下报错信息，应该怎么解决？
```
java.lang.NoSuchMethodError: org.apache.flink.api.java.ClosureCleaner.clean(Ljava/lang/Object;Z)V
```
A：该问题是因为所选择的huaweicloud-dis-flink-connector_2.11版本过低导致，请选择2.0.1及以上版本。

Q：运行作业读取DIS数据时，无法读出数据且Taskmanager的运行日志中有如下报错信息，应该怎么解决？

ERROR com.huaweicloud.dis.adapter.common.consumer.Coordinator      [] - Failed to getCheckpointAsync, error : [400 : {"errorCode":"DIS.4332","message":"app not found. "}], request : [{"stream_name":"xx","partition_id":"shardId-0000000000","checkpoint_type":"LAST_READ","app_name":"xx"}]

A: 该问题是因为读取DIS数据所使用的group.id在DIS的Apps中并没有提前创建。

上一篇：数据湖探索 DLI-scala样例代码:通过DataFrame API访问数据源

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