(DEPRECATED) Apache Flink User Mailing List archive.

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

Posted by Guowei Ma on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Adding-keyed-state-to-test-harness-before-calling-process-function-tp39438p39439.html

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 <[hidden email]> 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