问答 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 没有数据写入为啥?数据量是够的,消费任务都正常,就是没有数据写入,不知道数据怎么凭空消失了?

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

Flink CDC里flink on yarn,咋提交 CDC sql 任务呀?

Flink CDC里flink on yarn,咋提交 CDC sql 任务呀,必须得有 算子调用才能提交执行吗?

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

Flink CDC里并行度会任务会有什么影响?是-P这个参数吗?那-s呢?又是什么意思?

Flink CDC里并行度会任务会有什么影响?是-P这个参数吗?那-s呢?又是什么意思?视图有办法实时同步吗?

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

重启 flink cdc任务后,看着好像又重头开始了...如何解决呢?

重启 flink cdc任务后,看着好像又重头开始了...如何解决呢?

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

Flink CDC里提交两个任务读取sqlserver cdc怎么办?

Flink CDC里提交两个任务读取sqlserver cdc,java.lang.RuntimeException: One or more fetchers have encountered exception是要设置debezium 的servername吗?sqlserver 没有server id可配。报错2024-04-16 17:22:17java.lang.RuntimeExce....

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

产品推荐

阿里云实时计算Flink

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

+关注