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

在Flink CDC中checkpoint我设置3min他就同步速度很慢?

在Flink CDC中checkpoint为什么我设置了3000,它就同步速度很快,我设置3min他就同步速度很慢?

问答 2023-10-31 来自:开发者社区

Flink CDC我已经设置了ck超时时间5min,而且我发现在ck失败后不是会重启任务嘛?

Flink CDC我已经设置了ck超时时间5min,而且我发现在ck失败后不是会重启任务嘛,一直取消不掉任务,还把task给kill了,这咋排查呢? Exceeded checkpoint tolerable failure threshold. The latest checkpoint failed due to Checkpoint expired before completing., ....

问答 2022-09-17 来自:开发者社区

flink支持按不同粒度(1min、1hour、1day) 统计直播观看人数,应该怎么设计?

flink支持按不同粒度(1min、1hour、1day) 统计直播观看人数,应该怎么设计?

问答 2021-12-07 来自:开发者社区

flink 1.11 streaming 写入hive 5min表相关问题

现象: CREATE TABLE test.xxx_5min ( ...... ) PARTITIONED BY (dt string , hm string) stored as orc TBLPROPERTIES( 'sink.partition-commit.trigger'='process-time', 'sink.partition-commit.delay'='5 min'...

文章 2020-06-10 来自:开发者社区

详解 Flink DataStream中min(),minBy(),max(),max()之间的区别

解释 官方文档中: The difference between min and minBy is that min returns the minimum value, whereas minBy returns the element that has the minimum value in this field (same for max and maxBy). 翻译: min和minB....

问答 2020-06-03 来自:开发者社区

大家有遇到过这种应用场景么? flink流处理过程中需要延迟10min处理kafka中的数据,因为需

大家有遇到过这种应用场景么? flink流处理过程中需要延迟10min处理kafka中的数据,因为需要关联的维度信息10分钟之后才能就绪。 比如:01:10:00 处理01:00:00 对应的数据 01:10:01 处理01:00:01 对应的数据 .... #Flink

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

请问一下 。min("key"), minBy("key") 这个区别说的啥意思啊?#Flink

请问一下 。min("key"), minBy("key") 这个区别说的啥意思啊? 我运行的结果一模一样呀 #Flink

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

产品推荐

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

+关注
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等