闪光灯何时会在闪光灯中清理空闲状态？

Question

我正在使用眨眼计划程序。这是我的 sql

select * from test_table match_recognize (
   partition by agent_id,room_id,call_type 
   order by row_time // process time
   measures  
       last(BF.create_time) as create_time, 
       last(AF.connect_time) as connect_time 
   one row per match after match SKIP PAST LAST ROW 
   pattern (BF+ AF) WITHIN INTERVAL '10' SECOND 
   define 
       BF as BF.connect_time = 0,
       AF as AF.connect_time > 0  
) as T ;

test_table是Kafka桌

我设置了表.exec.state.ttl=10000 并运行我的程序，然后我继续发送消息。

由于我将状态ttl和cep interval都设置为10s，当我启动它时，状态的大小在10秒后应该是一个固定的数字。

但事实是，该州至少持续增长15分钟。此外，jvm触发了两次完整的gc。

是否有我尚未配置的配置

Answer 1

您不能使用检查点大小来估计状态大小——它们没有任何直接的关系。检查点可能包括数量不可预测的传输中、过期或未压缩的数据，这些数据都不会被视为活动状态。

恐怕没有任何好的工具可以精确测量您实际拥有的状态。但如果您使用的是RocksDB，则可以启用这些指标

state.backend.rocksdb.metrics.estimate-live-data-size
state.backend.rocksdb.metrics.estimate-num-keys

这将给你一个合理准确的估计（但你可能会因为打开它们而支付性能罚款）。

至于你对CEP状态的担忧 - 你应该没问题。只要您有使用 IN 的模式，CEP 就应该能够自动清理状态。