问个问题,一个有状态的flink程序消费kafka,如果切换kafka topic到一个#Flink

问个问题,一个有状态的flink程序消费kafka,如果切换kafka topic到一个新的topic,之前的状态是不是无法进行利用了?#Flink

Flink SQL 双流 Join ,默认永久保留状态,那么如何清理 双流 Join 的状态呢?

Flink SQL 双流 Join ,默认永久保留状态,那么如何清理 双流 Join 的状态呢? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
404 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

大数据知识图谱系列—基于ELK+Flink日志全观测最佳实践

1 课时 |
174 人已学 |
免费
开发者课程背景图

请教一下,flink任务不开启checkpoint的话,状态后端采用rocksdb的话,这种情况的出

请教一下,flink任务不开启checkpoint的话,状态后端采用rocksdb的话,这种情况的出来逻辑大概是什么样的呀?每条状态都读写rocksdb吗? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

State Processor API:如何读取,写入和修改 Flink 应用程序的状态

过去无论您是在生产中使用,还是调研Apache Flink,估计您总是会问这样一个问题:我该如何访问和更新Flink保存点(savepoint)中保存的state?不用再询问了,Apache Flink 1.9.0引入了状态处理器(State Processor)API,它是基于DataSet AP...

flink 中的rocksdb状态怎么样能可视化的查看有大佬知道吗?

flink 中的rocksdb状态怎么样能可视化的查看有大佬知道吗? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

请问Flink已经开启增量checkpoint,随着状态越来越大作业的checkpoint也越来越慢

请问Flink已经开启增量checkpoint,随着状态越来越大作业的checkpoint也越来越慢,这个怎么办呢?开始的时候毫秒就能完成checkpoint,现在基本都要几分钟 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

flink 双流union状态过期不清理有遇到的吗?

flink 双流union状态过期不清理有遇到的吗? 本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。 点击这里欢迎加入感兴趣的技术领域群。

Flink job 有多少种状态

Flink job 有多少种状态

flink运行的job里面我怎么取出rocksdb里面的状态数据呢

本问题来自阿里云开发者社区的【11大垂直技术领域开发者社群】。https://developer.aliyun.com/article/706511 点击链接欢迎加入感兴趣的技术领域群。

Flink在大规模状态数据集下的checkpoint调优

5万人关注的大数据成神之路,不来了解一下吗?5万人关注的大数据成神之路,真的不来了解一下吗?5万人关注的大数据成神之路,确定真的不来了解一下吗? 欢迎您关注《大数据成神之路》 今天接到一个同学的反馈问题,大概是: Flink程序运行一段时间就会报这个错误,定位好多天都没有定位到。checkpoint...

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

产品推荐

热门帮助文档

社区圈子

阿里云实时计算Flink
阿里云实时计算Flink
一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。
199201+人已加入
加入
相关电子书
更多
基于 Flink SQL + Paimon 构建流式湖仓新方
Flink中的两类新型状态存储
Apache Flink 流式应用中状态的数据结构定义升级
立即下载 立即下载 立即下载