Hi, Macro I think you could look at testScalingUp() at flink-state-backends/flink-statebackend-rocksdb/src/test/java/org/apache/flink/contrib/streaming/state/RocksIncrementalCheckpointRescalingTest.java Best, Guowei
On Fri, Nov 13, 2020 at 10:36 AM Marco Villalobos <mvillalo...@kineteque.com> wrote: > Hi, > > I would like to adding keyed state to test harness before calling process > function. > > I am using the OneInputStreamOperatorTestHarness. > > I can't find any examples online on how to do that, and I am struggling to > figure this out. > > Can somebody please provide guidance? My test case has keyed state > pre-populated as one of its pre-conditions. > > Thank you. Sincerely, > > Marco
