全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flink中状态TTL（生存时间）是什么？如何配置？

提问者：帅平问题分类：面试刷题

Flink面试题 Flink

发布于：3周前 (05-16) IP属地：

1 个回答

伤疤

Flink 状态 TTL（Time-To-Live，生存时间）是一种自动清理过期状态的机制，通过为状态设置存活时间，避免因状态无限增长导致的内存或存储资源耗尽。配置方法如下：
1、创建ttl配置

import org.apache.flink.api.common.state.StateTtlConfig;
import org.apache.flink.api.common.time.Time;
StateTtlConfig ttlConfig = StateTtlConfig.newBuilder(Time.days(7))  // 存活时间：7天
    .setUpdateType(StateTtlConfig.UpdateType.OnCreateAndWrite)     // 更新策略：仅在创建和写入时重置TTL
    .setStateVisibility(StateTtlConfig.StateVisibility.NeverReturnExpired) // 过期状态不可见
    .cleanupFullSnapshot()                                         // 全量快照时清理过期状态
    .build();

2、讲ttl关联到状态描述符

import org.apache.flink.api.common.state.ValueStateDescriptor;
ValueStateDescriptor<UserSession> sessionStateDescriptor = 
    new ValueStateDescriptor<>("userSessionState", UserSession.class);
sessionStateDescriptor.enableTimeToLive(ttlConfig); // 应用TTL配置

发布于：3周前 (05-16) IP属地：

我来回答