阿里云文档 2024-11-28

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

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

问答 2024-08-14 来自:开发者社区

Flink任务的checkpoint生成时间用了2分多钟 是正常的么?出现反压

Flink任务的checkpoint生成时间用了2分多钟 是正常的么?出现反压

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

使用Flink cdc 任务的检查点设置为增量的,看checkpoint确实是一增量的方式在保存吗?

使用Flink cdc 然后任务的检查点设置为增量的,但是好像没有效果。同样的配置,对kafka任务确是有用的,能看到checkpoint确实是一增量的方式在保存吗?

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

在Flink CDC中任务重启,从checkpoint恢复数据,binlog也存在,就是读取不到如何

在Flink CDC中任务重启,从checkpoint恢复数据,binlog也存在,就是读取不到如何解决?Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.9.7.Final,connector=mysql,name=mys....

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

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据

问题一:这种场景阿里云flink引擎有计划吗? flink 去 lookup join 一张实时写入的维表,在join不到情况下,加入缓存,然后delay retry。这种场景阿里云flink引擎有计划吗? 参考答案: 阿里云Flink引擎确实提供了一些功能来支持维表join操作的优化,但关于特定场景下“实时写入的维表在join不到时加入缓存并延迟重试...

实时计算 Flink版产品使用问题之如何实现重启后直接跑最新的任务而不是根据checkpoint跑历史数据
问答 2024-06-16 来自:开发者社区

E-MapReduce上的Flink任务的Checkpoint 写在哪里合适

E-MapReduce上的Flink任务的Checkpoint 写在哪里合适

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

Flink SQL计算任务从checkpoint恢复流程是怎样的

Flink SQL计算任务从checkpoint恢复流程是怎样的

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

flink cdc的pipeline配置文件方式配置任务,checkpoint间隔在哪里设置的?

flink cdc的pipeline配置文件方式配置任务,checkpoint间隔在哪里设置的?

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

flink cdc ci 提交任务的时候如何指定check point,哪位有用过?

flink cdc ci 提交任务的时候如何指定check point,哪位大佬有用过?

问答 2024-04-26 来自:开发者社区

Flink cdc任务运行中,日志出现这种情况,任务的checkpoint一直是成功状态然后咋办?

Flink cdc任务运行中,日志出现这种情况,然后任务的checkpoint一直是成功状态,但是没有继续采集数据了,请问有没有大佬知道是什么原因呀?

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

产品推荐

阿里云实时计算Flink

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

+关注