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

Flink CDC这个错误有人遇到过吗?文件已经存进阿里云OSS了但是清理策略删不掉2023-04-

Flink CDC这个错误有人遇到过吗?文件已经存进阿里云OSS了但是清理策略删不掉2023-04-20 18:28:49,020 WARN org.apache.flink.runtime.blob.FileSystemBlobStore [] - Failed to delete blob at oss://xxxx/flink/jobmanager-ha/flink...

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

我想每天的24点 定时清理 flink 的状态 可以做到吗?

我想每天的24点 定时清理 flink 的状态 可以做到吗?

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

请问flink sql 的windows操作,state会自动清理吗?

请问flink sql 的windows操作,state会自动清理吗?

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

Flink CDC状态数据是不是要定时清理啊?否则造成存储空间爆满,有什么参数可以设置吗?

Flink CDC状态数据是不是要定时清理啊?否则造成存储空间爆满,有什么参数可以设置吗?

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

Flink 大家一般是如何清理checkpoint?

Flink网上生产级要求,checkpoint需要手动写脚本清理,特别是增量的rocksdb, 大家一般是如何清理checkpoint?

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

flink 双流join checkpoint 一直在增加,状态怎么清理啊?

flink 双流join checkpoint 一直在增加,状态怎么清理啊,研究了好久都没弄明白,有大佬指导一下吗?

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

flink-sql 可以配置退出时不清理 checkpoint 嘛

然后重跑 sql 时,指定checkpoint 进行恢复

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

flink on yarn 怎么设置按周期清理下任务运行日志呢

flink on yarn 怎么设置按周期清理下任务运行日志呢

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

flink不清理state,从checkpoint恢复任务能重置kafka的offset讨论

Hi everyone: 如题,我遇到有些数据我不应该漏了想回溯部分数据,这个时候我就需要清理state,来重置kafka的offset重新跑,可不可以保留flink任务state,从checkpoint恢复任务的时候重置kafka的offset,并从kafka那个时间段开始消费,而不需要清掉state重新跑数据。*来自志愿者整理的flink邮件归档

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

flink sql子查询状态清理不掉

大家好,我现在程序里面有像这样一段sql:  select day,            count(id),            sum(v1) from ( select            day ...

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

产品推荐

实时计算 Flink

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

+关注