机器学习PAI的alink_server怎么调用flink的，是要在什么地方配置吗？[阿里云机器学习PAI] 暂停朗读为您朗读

对问题的解答如下:

问题一:PAI中的alink_server默认会自动检测和使用本地的Flink集群,无需额外配置。

问题二: 当alink_server启动在docker中时,它会自动使用docker内Flink;当在本地启动时,它默认查找本地启动的Flink集群。

所以如果从docker切换到本地,Flink环境就不一致了,需要修改配置让alink_server使用正确的Flink:

设置FLINK_HOME环境变量指向本地Flink安装目录

或者修改alink_server配置中flink.home参数

问题三: 由于Flink不一致导致任务提交失败。

解决方法:

从docker删除原Flink配置和状态

本地正确启动Flink集群

修改alink_server配置使用本地Flink

重新提交任务

所以要从docker切换到本地,需要确保Flink运行环境一致。可以先停止docker服务,加载本地Flink后再启动alink_server。