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

任务可以通过深度检查部署成功,但是启动会ddl超时默认的600s,Flink这个参数在哪里设置?

任务可以通过深度检查部署成功,但是启动会ddl超时默认的600s,Flink这个参数在哪里设置?

问答 2024-07-03 来自:开发者社区

请问下把flinkcdc的任务提交到flink集群运行有相应的API接口支持吗?

请问下把flinkcdc的任务提交到flink集群运行有相应的API接口支持吗?

文章 2024-06-11 来自:开发者社区

人工智能平台PAI操作报错合集之alink任务可以在本地运行,上传到flink web运行就报错,如何解决

问题一:机器学习PAI模型使用mmoe+din+senet时,遇到如下错误,帮忙看看时怎么回事? 机器学习PAI模型使用mmoe+din+senet时,遇到如下错误,帮忙看看时怎么回事哈 ValueError: Variable se_net_1/W1/kernel does not exist, or was not created with tf.get_varia...

人工智能平台PAI操作报错合集之alink任务可以在本地运行,上传到flink web运行就报错,如何解决
问答 2024-05-28 来自:开发者社区

flinkcdc3 cli如何提交任务到远程flink 集群环境呢?

flinkcdc3 cli如何提交任务到远程flink 集群环境呢?

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

机器学习PAI的alink任务在本地运行好好的,上传到flink web运行就报这个错误。怎么解决?

机器学习PAI的alink任务在本地运行好好的,上传到flink web运行就报这个错误。怎么解决?org.apache.flink.runtime.rest.handler.RestHandlerException: Could not execute application. at org.apache.flink.runtime.webmonitor.handlers.JarRunHand....

问答 2023-11-22 来自:开发者社区

我在这个任务里配置了7个表,只同步了前4个表,Flink是需要等待还是说我的配置问题?

我在这个任务里配置了7个表,资源的设置是这样子的 但是同步的时候 只同步了前4个表,Flink是需要等待还是说我的配置问题?

问答 2023-09-19 来自:开发者社区

Sink任务都是并发,这个用Flink SQL有没有办法做到我想要的效果呢?

我现在用的是Flink 1.16 版本,目前我有这么一个需求,在一个任务中,我会消费Kafka的消息(source),结合已有的表,生成3个结果表,分别Sink到PG的3个表中,当这3个Sink完成后,我还需要Sink一条消息回Kafka中,告诉别人我这个任务已民经完成了。目前我了解下来,Sink任务都是并发,这个用Flink SQL有没有办法做到我想要的效果呢?

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

我任务现在大面积报错ck失败 跟上午发那个原因一致 是Flink CDC版本问题导致的嘛?

我任务现在大面积报错ck失败 跟上午发那个原因一致 是Flink CDC版本问题导致的嘛?

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

升级版本的话我任务岂不是都要停止重新跑, 2.3支持flink1.13.6么?

升级版本的话我任务岂不是都要停止重新跑, 2.3支持flink1.13.6么?我想不影响线上任务的情况下升级版本咋做,主要是线上任务有点多 将近100个 都要重新搞动静有点大

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

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?

scala中关闭任务结束后的 Checkpoint,Flink设置的时候报异常,怎么解决?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注