阿里云文档 2025-03-10

如何通过DataStream的方式读写数据

本文为您介绍如何使用DataStream连接器,即通过DataStream的方式读写数据。

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

Flink state ttl设置后未生效

Flink state ttl设置后未生效

文章 2024-02-26 来自:开发者社区

flink问题之state过期设置如何解决

问题一:flink任务提交方式 请问现在flink有没有像sparklauncher这种任务提交方式,在任务提交成功后返回对应的任务id(不管是onyarn还是standlone),我这面想用java代码提交任务并在提交后获取任务id,请问有没有对应功能或工具 参考回答: 1.10.x版本以后env.execute()是返回一个JobExecution...

问答 2023-09-06 来自:开发者社区

Flink CDC的 state ttl在哪里设置?

Flink CDC的 state ttl在哪里设置?

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

Flink中我的State 数据过期时间设置24h,但ck列表里只显示最近30分钟的检查点。正常吗?

Flink中我的State 数据过期时间设置24h,但是ck列表里只显示最近30分钟的检查点。正常吗?

问答 2023-06-11 来自:开发者社区

大家好。 flink1.15.2使用hdfs的filesystem做存储,现在对state设置?

大家好。 flink1.15.2使用hdfs的filesystem做存储,state backend为EmbeddedRocksDBStateBackend。 现在对state设置ttl,报这个错? 请问有人遇到过吗?怎么解决的?

问答 2023-05-09 来自:开发者社区

大佬们求教下 Flink CDC 中state backends设置为rocksdb,并设置使用增量

大佬们求教下 Flink CDC 中state backends设置为rocksdb,并设置使用增量快照,那么生成的checkpoints文件会一直覆盖之前的还是会根据checkpoint id依次保留?

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

请问各位大佬,flink-cdc 做regular join state设置永不过期会有问题,但是

请问各位大佬,flink-cdc 做regular join state设置永不过期会有问题,但是我们的业务场景需要state内保存全量数据,有什么其他解决方案吗?(业务场景无法做 interval join ) 我们目前是通过flink-kafka 处理, 定时向kafka内同步历史数据,从而保证flink内一直有全量数据; 但是定时同步会有短时间的反压问题。

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

Flink sql的state ttl设置

大家好: 版本:1.12.0 方式:Flink sql table.exec.state.ttl 和 tConfig.setIdleStateRetention() 对于flink sql,这两种作用是一样的吗?*来自志愿者整理的flink邮件归档

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

flink的state过期设置

想咨询一下关于state的ttl问题; 想问一下 state设置的ttl,如果从checkpoints重启 ttl会不会失效;ttl针对的是process time, 比如我设置的7天过期,重新从checkpoints启动是第一次启动的时间算还是恢复时的新processtime算;他是state的一部分 还是怎么算; 或者要注册定时器来实现 *来自志愿者整理的flink邮件归档

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

产品推荐

实时计算 Flink

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

+关注