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

hbase 列设置TTL过期后,flink不能再写入数据

Flink:1.12.1 Flink-connector: 2.2 Hbase: 2.1.0 + CDH6.3.2 现象:如果hbase列族设置了TTL,当某一rowkey写入数据,到达过期时间,列族会被hbase标记为删除。 后续如果有相同key的数据过来,flink无法将数据写入到hbase中,查询hbase中列族一直为空。 执行的过程大致如下: 创建Hbase表,test, 两...

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

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

rt*来自志愿者整理的flink邮件归档

问答 2021-01-31 来自:开发者社区

flink的定时器可以实现这个功能吗 就是刚开始定时 之后过期时间是一天 如果在这一天内#Flink

flink的定时器可以实现这个功能吗 就是刚开始定时 之后过期时间是一天 如果在这一天内满足了某个要求 想要重新定时 这样的话 在OnTimer函数会执行几次逻辑啊#Flink

问答 2021-01-24 来自:开发者社区

flink 1.11 sql状态的过期时间官网那里有介绍?#Flink

flink 1.11 sql状态的过期时间官网那里有介绍?#Flink

问答 2021-01-05 来自:开发者社区

Flink 状态过期是如何清理的?

Flink 状态过期是如何清理的?

问答 2021-01-05 来自:开发者社区

Flink DataStream 状态过期是怎样配置的

Flink DataStream 状态过期是怎样配置的

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

assignTimestampsAndWatermarks这个方法被标记过期了,现在有出#Flink

assignTimestampsAndWatermarks这个方法被标记过期了,现在有出来什么替代的方法吗?#Flink

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

状态的过期时间,哪里可以设置?现在项目上用到了flink,只会flink sql #Flink

状态的过期时间,哪里可以设置?现在项目上用到了flink,只会flink sql #Flink

问答 2019-11-26 来自:开发者社区

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

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

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

Flink写入hbase遇到kerberos过期

使用flink 将数据写入hbase,任务运行1天后,报错: GSS initiate failed [Caused by GSSException: No valid credentials provided (Mechanism level: Failed to find any Kerberos tgt)

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

产品推荐

阿里云实时计算Flink

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

+关注