问答 2024-11-25 来自:开发者社区

alink任务本地正常运行,发布到flink集群后报错

本地运行一个alink任务,大概流程监听kafka中的数据,并作为入参结合已经使用线性回归算法训练好的数据集做运行,可以正常运行得到结果。但是,将该任务通过flink web ui发布到集群后,运行就报错了。flink是1.13版本,alink是1.6.0版本,可能是什么问题导致的?

问答 2024-05-20 来自:开发者社区

Flink提交任务到yarn 集群 报错?有遇到过类似的错误吗?

Flink提交任务到yarn 集群 报错?有大佬遇到过类似的错误吗?Diagnostics from YARN: Application application_1715652296904_0003 failed 1 times (global limit =2; local limit is =1) due to AM Container for appattempt_171565229690....

问答 2024-05-01 来自:开发者社区

Flink CDC里大佬这里监控mysql集群 这个报错怎么解决?

Flink CDC里大佬这里监控mysql集群 这个报错怎么解决?

文章 2024-03-17 来自:开发者社区

Flink CDC产品常见问题之flink集群jps命令报错如何解决

问题一:有人用过Flink CDC 3.0版本的整库同步吗? 有人用过Flink CDC 3.0版本的整库同步吗?我用Flink CDC3.0整库同步mysql到starRock提交任务异常,有人遇到过这个问题吗? ...

Flink CDC产品常见问题之flink集群jps命令报错如何解决
文章 2024-02-24 来自:开发者社区

Flink问题之本地集群报错如何解决

问题一:pyflink使用的一些疑问 你好, 最近项目想使用flink进行分布式计算,之前项目是Python的pandas项目,想尝试用pyflink进行项目改造,在使用dataset做批处理时,对于Java的版本没有相关map reduce函数,所以有以下疑问: 1.Python flink的SDK还没支持dataset吗? 2.是不是有其他替代方法?...

问答 2024-02-06 来自:开发者社区

Flink CDC里我的flink集群的checkpoint文件是存在本地的,报错怎么解决?

Flink CDC里我的flink集群的checkpoint文件是存在本地的,然后我手动kill掉taskmanager,任务在其他机器上重启时,报错找不到checkpoint文件,这种情况怎么解决?通过state.checkpoints.dir这个配置在集群所有机器全部创建checkpoint文件么?

问答 2024-01-24 来自:开发者社区

Flink CDC里 flink集群jps命令 报错怎么办?

Flink CDC里 flink集群jps命令 报错java.lang.OutOfMemoryError: unable to create new native thread 内存不足无法创建新的进程 我看了下机器内存情况 好像确实不多了 但是buffer 和available里面有 是不是没释放啊 ?

问答 2023-12-20 来自:开发者社区

FlinkCDC在通过flink集群提交jar时,会报错BlobServer错

FlinkCDC在通过flink集群提交jar时,会报错Caused by: java.io.IOException: Could not connect to BlobServer at address localhost/127.0.0.1:6124。提交的命令为:flink run -m **:8081 -c /home/flink/jars/flink-app-129080853345.....

问答 2023-12-06 来自:开发者社区

Flink因为session集群无法启动,提示要剔除参数。剔除后调试的时候又报错,这应该怎么处理啊?

Flink因为session集群无法启动,提示要剔除参数。剔除后session集群能启动了,但是调试的时候又报错,这应该怎么处理啊?

问答 2023-08-20 来自:开发者社区

Alink任务发送到远程Flink集群上测试一段时间后集群挂了发现机器学习PAI的报错怎么办?

Alink任务发送到远程Flink集群上测试一段时间后集群挂了,我们发现下面的报错,请教是什么原因? 2023-08-18 13:16:16,491 ERROR com.alibaba.alink.common.io.annotations.AnnotationUtils [] - Multiple IO Operator class with same name redis and ...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注