Re: Adding keyed state to test harness before calling process function.

2020-11-15 Thread Guowei Ma
t;> 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...@kineteq

Re: Adding keyed state to test harness before calling process function.

2020-11-12 Thread Marco Villalobos
> > 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 OneInputStreamOperatorTestHar

Re: Adding keyed state to test harness before calling process function.

2020-11-12 Thread Guowei Ma
; 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 g

Adding keyed state to test harness before calling process function.

2020-11-12 Thread Marco Villalobos
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