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

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

Flink cdc任务在同步过程中新增同步表后选择全量初始化历史数据,会阻塞原先其余表的增量同步么?

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

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

锁表会导致 flink任务的GC吗?

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

Flink CDC里任务都停了,内存资源不释放是什么情况?

Flink CDC里任务都停了,内存资源不释放是什么情况?

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

flink cdc到doris,如果mysql中的表被删除或者rename,同步任务会报错么?

flink cdc到doris,如果mysql中的表被删除或者rename,同步任务会报错么?

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

Flink CDC里任务启动后一直处于starting是咋回事儿?

Flink CDC里任务启动后一直处于starting是咋回事儿?内存占用也还有。启动了大概400个任务,内存三台机器还剩300g。

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

Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig

Flink1.18.1和CDC2.4.1 本地没问题 提交任务到服务器 报错java.lang.NoClassDefFoundError: Could not initialize class io.debezium.connector.mysql.MySqlConnectorConfig 这个错误是因为在服务器上缺少了Debezium的MySQL连接器依赖。你需要将Debezium的MySQL....

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

flink的jar包任务,如果要配置日志级别修改为debug,这个是在哪里改呢?

flink的jar包任务,如果要配置日志级别修改为debug,这个是在哪里改呢?

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

我flink stream任务只有输入-》窗口算子-》输出,也没法一次性获取并输出么?

我flink stream任务只有输入-》窗口算子-》输出,窗口时间用的是processtime,窗口函数是processWindowFunction,窗口大小是30s,刚启动我看窗口算子receive的记录就已经达到源端的数据上限了,所以按道理不到30s,源端所有数据都应该进入窗口了,那么数据应该一次性从窗口算子中输出,按道理应该不到一分钟就应该跑完了,但是我看窗口算子下游还在慢慢传出数据,持....

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

Flink CDC 里用虚拟内存跑任务会不会很慢呀?

Flink CDC 里用虚拟内存跑任务会不会很慢呀?

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

flink cdc 怎么用定时执行批任务?

flink cdc 怎么用定时执行批任务? ververica connector clickhouse 支持flink sql 吗?

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

产品推荐

阿里云实时计算Flink

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

+关注