文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之nk任务在k8s上运行,数据量大时经常失败,并且某个TaskManager被cgroup杀掉,该如何处理

问题一:Flink CDC读貌似是有符号的-128---127? Flink CDC读貌似是有符号的-128---127?sqlserver的tinyint是0-255 ...

实时计算 Flink版产品使用合集之nk任务在k8s上运行,数据量大时经常失败,并且某个TaskManager被cgroup杀掉,该如何处理
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之归档日志定时清理导致任务失败如何解决

问题一:用的什么开源平台来处理flinkCDC任务? 用的什么开源平台来处理flinkCDC任务? 参考回答: 对于管理和调度Flink CDC任务,有几个常见的开源平台可供选择: Apache Airflow:Apache Airflow 是一个用于编排、调度和监控工作流的开源平台。您可以使用Airflow来创建和调度Flink ...

实时计算 Flink版产品使用合集之归档日志定时清理导致任务失败如何解决
文章 2024-05-23 来自:开发者社区

实时计算 Flink版产品使用合集之如何查看任务的上下游依赖关系

问题一:flink的TaskManager和slot是一对一的,这个能调整成1对多么? flink的TaskManager和slot是一对一的,这个能调整成1对多么? 参考回答: 在Flink中,TaskManager是任务执行的负责者,而Slot则是任务的最小执行单位。每个TaskManager是一个JVM进程,它可能在独立的线程上执行一个或多个su...

实时计算 Flink版产品使用合集之如何查看任务的上下游依赖关系
问答 2024-05-22 来自:开发者社区

升级的时候我需要停止flink任务么?

升级的时候我需要停止flink任务么?

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

在Flink我一个任务中有多个sink,当我增加一个新的sink时,无法从状态恢复,怎么解决?

在Flink我一个任务中有多个sink,当我增加一个新的sink时,无法从状态恢复,怎么解决?

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

Hologres升级的时候我需要停止flink任务么?可以直接升级到2.1么?

Hologres升级的时候我需要停止flink任务么?可以直接升级到2.1么? 这样我们少停几次

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

Flink CDC里pgsql开启cdc监听任务报错怎么办?

Flink CDC里pgsql开启cdc监听任务报错怎么办?pgoutput这个需要改哪里?

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

flink cdc集群多个节点,任务如何均分到各个节点上,哪个参数设置?

flink cdc集群多个节点,任务如何均分到各个节点上,哪个参数设置,flink1.18

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

我flink SQL 任务 +rockdbs,那我设置三分钟状态有效期 不会使得cp 状态减少吗 ?

我flink SQL 任务 +rockdbs,那我设置三分钟状态有效期 不会使得cp 状态减少吗 ?是不是目前flink底层没有支持这个功能?

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

大家有谁迁移过Flink任务吗?

大家有谁迁移过Flink任务吗,从A服务器Flink集群,迁移到B服务器Flink集群, 有啥经验传授的没?

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

产品推荐

阿里云实时计算Flink

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

+关注