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

Flink cdc 1.18提交到k8s 任务过一会自动cancel 有人遇到同样的问题嘛?

Flink cdc 1.18提交到k8s 任务过一会自动cancel 有人遇到同样的问题嘛?

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

Flink使用单作业模式提交任务到yarn,出现这个错误怎么解决呀?

Flink使用单作业模式提交任务到yarn,出现这个错误怎么解决呀?

文章 2024-04-28 来自:开发者社区

人工智能平台PAI 操作报错合集之在集群上提交了包含alink相关功能的flink任务,但是却报错如何解决

问题一:使用机器学习PAI又报这种错误怎么办? 使用机器学...

人工智能平台PAI 操作报错合集之在集群上提交了包含alink相关功能的flink任务,但是却报错如何解决
问答 2024-04-26 来自:开发者社区

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,什么时候开始增量?

Flink cdc任务在同步过程中 新增同步表后选择全量初始化历史数据,如果十几个小时才能初始化完成,无锁算法开始增量的时候是从十几个小时前的binlog位点增量还是从当前时间位点增量?(如果是从十几个小时前的binlog位点衔接增量,如果binlog已经归档了,就会报错文件找不到)

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

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

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

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

flink批处理任务 137 Killed by external signal该如何解决

FLink版本1.14.6使用的是pyflink做的批处理逻辑上是有个大表join小表,然后用了个map算子,调用了个row函数,使用table数据和stream数据互转的方式,手动提高了并行度,然后调用map操作,row函数里处理逻辑很多。集群规模是3*16G内存,Hadoop集群,使用yarn perjob的形式提交的任务。 当我的主表有4.1w的数据量,程序可以在4min内执行完,但是当我....

文章 2024-04-24 来自:开发者社区

[flink 实时流基础] flink组件栈以及任务执行与资源划分

7. Flink组件栈 我们从更宏观的角度来对Flink的组件栈分层剖析。Flink的组件栈分为4层:部署层、运行时层、API层和上层工具。 1. 部署层 Flink支持多种部署模式,可以部署在单机(Loca...

[flink 实时流基础] flink组件栈以及任务执行与资源划分
问答 2024-04-24 来自:开发者社区

Flink能不能后期加个任务名称改变的功能?或者复制功能?

Flink能不能后期加个任务名称改变的功能?或者复制功能?方便管理

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

Flink CDC 如何实现断点续传的功能呢?那如果是Flink任务报错崩掉的情况呢?

Flink CDC 任务报错崩掉如何实现断点续传的功能呢?

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

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,为啥这样?

Flink CDC里flinksql 一个并发写mysql 正常,2个并发消费任务都正常,但是mysql 没有数据写入为啥?数据量是够的,消费任务都正常,就是没有数据写入,不知道数据怎么凭空消失了?

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

产品推荐

阿里云实时计算Flink

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

+关注