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

有遇到过kerberos环境下,flink 写hudi 认证24小时过期的问题么,如何续期呢?

有遇到过kerberos环境下,flink 写hudi 认证24小时过期的问题么,如何续期呢?

问答 2022-12-21 来自:开发者社区

flink on yarn kerberos 七天过期,checkpoint失败了,大家是怎么处理的

flink on yarn kerberos 七天过期,checkpoint失败了,大家是怎么处理的?

问答 2022-10-24 来自:开发者社区

flink将checkpoint写入到hdfs中七天之后token过期,有大佬解决过这个问题吗?

flink将checkpoint写入到hdfs中七天之后token过期,有大佬解决过这个问题吗?

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

请各位大神指点一下,使用flink将数据写入到HIVE中,过几天之后token自动过期 导致执行不成

请各位大神指点一下,使用flink将数据写入到HIVE中,过几天之后token自动过期 导致执行不成功,有解决办法吗

问答 2022-07-04 来自:开发者社区

麻烦问下,flink表数据会删除或者过期吗?我需要针对全量和增量的数据做聚合操作

麻烦问下,flink表数据会删除或者过期吗?我需要针对全量和增量的数据做聚合操作

文章 2021-12-24 来自:开发者社区

Flink线上问题汇总篇(1)-状态过期导致的sum结果负数问题

flink任务上线运行有一段时间了一直很稳定,这两天忽然发现有些“丢数据”的现象。这是怎么回事呢?用这篇文章记录一下踩坑之路。任务要求: 我们这个任务要达到的效果是汇总每月的业务量,需要按照具体分类分组。业务量绝对不会出现负数的问题,但是现在汇总出来的居然存在负数!肯定是某个环节出现了问题。排查思路: 我这个任务使用的是flink的table api操作比较简单。最先发现数据不正常是发现fl...

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

Flink sql 状态过期后,checkpoint 大小没变化

大家好: 版本:1.12.0 方式:flink sql 测试sql: select a.id,b.money,b.createTime from test_state_from a full join test_state_from1 b on a.id=b.id; 问题: test_state_from和test_state_from1 分别插入50万条数据,查看 checkpoint 大小为....

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

每次 flink cancel -s 后生成的 savepoint 目录不断变大。是过期清除策略没生

flink-1.7.2, 用下面的清除策略:StateTtlConfig ttlConfig = StateTtlConfig .newBuilder(Time.days(3)).setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite).setStateVisibility(StateTtlConfig.StateVisibility.N....

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

flink的state过期设置

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

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

Flink操作 kafka ,hive遇到kerberos过期

请问下 Flink操作 kafka ,hive遇到kerberos过期 有什么解决方法吗?*来自志愿者整理的flink邮件归档

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

产品推荐

阿里云实时计算Flink

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

+关注