jeff-zou / flink-connector-redis

Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.
Apache License 2.0
220 stars 80 forks source link

hset命令下ttl不断重置的问题 #45

Closed ancientMuse closed 11 months ago

ancientMuse commented 1 year ago

写flink sql,使用hset命令,同时配置了ttl参数,但发现每次hset同一个key的时候,ttl会被重置,极限情况下,这个key可能永远都不会过期了,有没有相关参数可以避免这个情况

jeff-zou commented 1 year ago

默认情况下map数据更新,ttl应该也更新。 你是想实现ttl只计算第一次写入时间么?

ancientMuse commented 1 year ago

默认情况下map数据更新,ttl应该也更新。 你是想实现ttl只计算第一次写入时间么?

是的,一些业务场景里只需要对一级key做ttl,hset只是在key有效期内更新内容

jeff-zou commented 11 months ago

已更新代码,增加了参数 ttl.key.not.absent, 与ttl一起使用,作用是当key不存在时才设置ttl

jeff-zou commented 11 months ago

https://github.com/jeff-zou/flink-connector-redis/releases/tag/1.3.1 已发布,请使用: `

io.github.jeff-zou
<artifactId>flink-connector-redis</artifactId>
<!-- 没有单独引入项目依赖Lettuce netty-transport-native-epoll依赖时 -->
<!--            <classifier>jar-with-dependencies</classifier>-->
<version>1.3.1</version>

`