阿里云文档 2024-11-28

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

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

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

实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理

问题一:我使用Flink CDC 3.0对mysql整库同步到starrock中,任务挂掉是为啥? 我使用Flink CDC 3.0对mysql整库同步到starrock中,现在任务已经创建好了,mysql的表和数据都同步到starrock中了,现在发现的问题是,我在源表加了新字段,接着flink的任务就挂掉了是为什么? ...

实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理
问答 2024-07-11 来自:开发者社区

Flink在HA模式,重启ZK集群,客户端任务提交异常(疑似脑裂)

基本信息 Flink 1.11.6版本,Standalone HA模式, 滚动重启了ZK集群在Flink集群的一个节点上使用flink run 命令提交多个任务 异常现象 部分任务提交失败,异常信息如下 [Flink-DispatcherRestEndpoint-thread-2] - [WARN ] - [org.apache.flink.runtime.rpc.akka.AkkaInvoc.....

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

Flink任务提交后出现这个异常要怎么处理呀 ?

Flink任务提交后出现这个异常要怎么处理呀 ?

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

实时计算 Flink版操作报错合集之CDC任务在异常后整个record sent从0初始化开始,是什么导致的

问题一:Flink CDC中,分片表添加字段报错,可以看下吗 ? Flink CDC中,分片表添加字段报错,可以看下吗 ? 参考回答: 根据提供的错误信息,可以看出是在使用Flink CDC(Change Data Capture)时出现了异常。具体错误为java.lang.IllegalArgumentException: add column of AddC...

实时计算 Flink版操作报错合集之CDC任务在异常后整个record sent从0初始化开始,是什么导致的
问答 2024-06-16 来自:开发者社区

请问Flink任务提交后出现这个异常要怎么处理呀 ?

请问Flink任务提交后出现这个异常要怎么处理呀 ?然后执行一会又抛这个异常?

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

在Flink CDC中请问任务提交后出现这个异常要怎么处理呀 ?

在Flink CDC中请问任务提交后出现这个异常要怎么处理呀 ?请参考图片:

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

实时计算 Flink版产品使用问题之全量快照初始化时,如果任务异常自动从ck restore后,会从上次binlog断点续传吗

问题一:Flink CDC 里flink application 模式提交能声明环境变量不? Flink CDC 里flink application 模式提交能声明环境变量不? 参考答案: 当使用 ./bin/flink run-application 命令提交 Flink 应用程序时,可以在命令行中添加 -Dkey=value 格式的 JVM 系统...

实时计算 Flink版产品使用问题之全量快照初始化时,如果任务异常自动从ck restore后,会从上次binlog断点续传吗
问答 2024-06-04 来自:开发者社区

Flink任务taskmanager异常退出原因及解决方案

Flink任务taskmanager异常退出原因及解决方案

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

Flink如何查看任务异常原因

Flink如何查看任务异常原因

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

产品推荐

阿里云实时计算Flink

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

+关注