阿里云文档 2024-11-28

如何在Dataphin自定义Ververica Flink实时任务的资源

Ververica Flink实时任务资源自定义,即指实时计算Flink配置细粒度资源的专家模式 (BETA),Flink全托管引入的全新的资源配置模式,支持对作业所使用的资源进行细粒度的资源控制,以满足作业吞吐的要求。系统会自动根据您配置的资源需求,以Native K8s的模式运行作业,TM的规格和个数将会根据Slot的规格和作业并发度,由系统自动决定。本文将介绍如何在Dataphin自定义Ve...

阿里云文档 2024-04-16

Flink_SQL任务开发方式有哪些

Dataphin的Flink_SQL任务支持多种开发方式,包括原生DDL+DML开发、使用Dataphin元表进行开发、使用Dataphin数据源表进行开发、以及使用计算源物理表进行开发,且不同开发方式所创建的表支持任意混用,包括镜像表。不同开发方式的使用方法、使用场景以及优缺点不同。本文将为您介绍各开发方式帮助您更好的完成Flink_SQL任务开发。

问答 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设置的时候报异常,怎么解决?

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

有个任务在阿里云Flink跑着跑着就出现OOM,但我们不能开普罗米修斯去监测,你们有办法吗?

Flink有个任务在阿里云FLINK跑着跑着就出现OOM,但我们又不能开普罗米修斯去监测,你们这边可以有办法帮到我们吗?不想开监控,费用贵,运行日志排查可以吗?

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

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

请问flink1.16任务执行时 flink-rocksdb目录下没state文件 是哪儿没配对吗?

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

产品推荐

实时计算 Flink

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

+关注