Hi, I'm attempting to unit test a KeyedProcessFunction that uses v2 Async State API using "ProcessFunctionTestHarnesses.forKeyedProcessFunction()". When I run my test it fails with:
"Caused by: java.lang.IllegalStateException: Current operator integrates the async processing logic, thus only supports state v2 APIs. Please use StateDescriptor under 'org.apache.flink.runtime.state.v2'." I ran into a similar issue when attempting to run integration tests for the function even though I confirmed I'm using the .v2. packages and properly calling ".enableAsyncState()". After finding these two issues in Jira: https://issues.apache.org/jira/browse/FLINK-37621 https://issues.apache.org/jira/browse/FLINK-37623 I updated my project to use Flink 2.1.0-SNAPSHOT. That fixed my integration test, but my unit test is still failing. I'm not sure if I'm doing something wrong in my test or if maybe ProcessFunctionTestHarnesses doesn't support Async State yet. Any ideas? Thanks! Nate
