How can I properly test my

ValueState

Ttl config? I set the Ttl in my

open

override, but when I set the processing time it doesn't seem to affect the state ttl in my tests.

You might want to take a reference to the operator test harness.

I tried that, but had trouble initializing the

KeyedOneInputStreamOperatorTestHarness

. I kept getting cannot infer type. Do you have an example? My setup is

<K, IN, OUT> = Tuple2<String, String>, inputClass, outputClass

You might want to take a look at RankHarnessTest `testRetractRankWithRowNumber`to see

testHarness#setStateTtlProcessingTime

Got it, thanks!