人工智能平台PAI 操作报错合集之在集群上提交了包含alink相关功能的flink任务，但是却报错如何解决-阿里云开发者社区

人工智能平台PAI 操作报错合集之在集群上提交了包含alink相关功能的flink任务，但是却报错如何解决

2024-04-28 217

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： 阿里云人工智能平台PAI (Platform for Artificial Intelligence) 是阿里云推出的一套全面、易用的机器学习和深度学习平台，旨在帮助企业、开发者和数据科学家快速构建、训练、部署和管理人工智能模型。在使用阿里云人工智能平台PAI进行操作时，可能会遇到各种类型的错误。以下列举了一些常见的报错情况及其可能的原因和解决方法。

问题一：使用机器学习PAI又报这种错误怎么办？

使用机器学习PAI又报这种错误怎么办？这次连提交job都提交不了了

参考答案：

根据您提供的错误信息，这是一个内部服务器错误。为了解决这个问题，您可以尝试以下方法：

检查您的代码是否有语法错误或逻辑错误。确保您的代码可以正常运行。
查看PAI的官方文档和社区支持，看看是否有其他人遇到了类似的问题并找到了解决方案。
如果问题仍然存在，您可以尝试在PAI集群中运行一个简单的示例程序，以排除其他潜在问题。例如，您可以使用以下命令运行一个简单的线性回归模型：

alink run -m local -f linear_regression -d input_data.csv -o output_model

其中，input_data.csv是您的输入数据文件，output_model是输出模型文件。

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/569660

问题二：我现在在机器学习PAI的集群上提交了包含alink相关功能的flink任务，但是却报这样的错。

我现在在集群上提交了包含alink相关功能的flink任务，但是却报这样的错。我在idea上跑是没问题的，而且也去除了log4j相关的依赖。有没有大佬碰见过这样的问题的？我服务器上的flink是用docker启的，和本地的flink版本都是1.9.0

参考答案：

slf4j没引好吧，看看FLINK平台里引的JAR包和版本和本地不一样的地方。FLINK平台里有原始自带的JAR 包。和你打包的又不一样。flink平台里的自带的其他jar包，不是flink jar 包 https://github.com/alibaba/Alink/blob/master/docs/deploy/cluster-deploy.md 把shade后的包放进lib目录，然后配置上classloader.resolve-order: parent-first，然后提交的时候把shipjars这个选项关了，应该就可以了

关于本问题的更多回答可点击进行查看：

https://developer.aliyun.com/ask/569658

问题三：如下，请问机器学习PAI的这个问题怎么解决？

请教一个flinksql 问题，要求是每来一条输出一次结果，计算一个数值按照group id，现在发现我一次发多条数据的时候，可能会触发一起计算，不是一条条的，有啥办法处理嘛

参考答案：

在Flink SQL中，可以使用窗口函数（Window Function）来实现每条数据单独计算的需求。具体来说，可以使用ROW_NUMBER()窗口函数为每个分组内的数据分配一个唯一的序号，然后根据这个序号进行计算。

以下是一个示例：

SELECT
  id,
  group_id,
  value,
  -- 使用ROW_NUMBER()窗口函数为每个分组内的数据分配一个唯一的序号
  ROW_NUMBER() OVER (PARTITION BY group_id ORDER BY id) AS row_num,
  -- 根据序号计算结果
  value * row_num AS result
FROM
  your_table;