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

另外flink cdc有没有类似消费哪个位点信息?类似slave

没有现在spark,不知道怎么监控,另外flink cdc有没有类似消费哪个位点信息?类似slave这种

问答 2024-08-21 来自:开发者社区

flink作为source jar作业代码里面消费位点的订阅方式 和控制台的有无状态启动有冲突吗?

flink作为source jar作业代码里面消费位点的订阅方式 和控制台的有无状态启动有冲突的么? 比如代码里面是从最早位点消费 在控制台无论选择哪种启动 都会从最早位点消费的

问答 2024-07-11 来自:开发者社区

Flink的快照位点大概可以保留多久的 3天的么?

Flink的快照位点大概可以保留多久的 3天的么?

问答 2024-07-11 来自:开发者社区

Flink如果停止了再启动 任务会从停止时候的位点继续消费么 ?

如果通过cdc把数据同步到datahub上面 datahub再转发到flink(主要是为了数据重放) 接受datahub数据的flink任务 Flink如果停止了再启动 任务会从停止时候的位点继续消费么 ?

问答 2024-07-02 来自:开发者社区

对于Flink CDC,从mysql到doris数据同步,同步位点信息存在哪里?

对于Flink CDC,从mysql到doris数据同步,同步位点信息存在哪里?

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

在Flink如果cdc任务 关闭再重启 能保证消费位点的准确性么?

在Flink如果cdc任务 关闭再重启 能保证消费位点的准确性么?

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

实时计算Flink版的MySQLCDC如何从指定位点读取数据

实时计算Flink版的MySQLCDC如何从指定位点读取数据

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

Flink读取MaxCompute设置启动位点无效

Flink读取MaxCompute设置启动位点无效

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

Flink消费Kafka时提交位点时间间隔如何减少

Flink消费Kafka时提交位点时间间隔如何减少

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

Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效怎么办?

Flink CDC里目前遇到一个问题,rds扩缩容是 会导致binlog位点失效,从而引发作业一直重启失败,flinkcdc有什么 方法可以规避这种情况吗?没有用过gtid,是需要rds这边配置吗?确实是凌晨低峰进行的。

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

产品推荐

阿里云实时计算Flink

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

+关注