Hi Nate, Hi Lasse,
FYI, if you're still interested in the test harness for KeyFunctions with State
V2, please note that the ticket [1] mentioned earlier has been resolved.
Although it hasn't been officially released yet, you can try out the new
harness methods. These methods can be found in the
Hi NateThanks for informing me. I will give it a try. Med venlig hilsen / Best regardsLasse NedergaardDen 24. jun. 2025 kl. 05.48 skrev Han Yin :Hi Nate, Hi Lasse,FYI, if you're still interested in the test harness for KeyFunctions with State V2, please note that the ticket [1] mentioned earlier h
HiSo the conclusion is that it isn’t possible at all to test key functions using the new DataStream api as it requires state V2 and test support is missing. And it isn’t possible to declare and use state V1 together with the new DataStream api as a temporary solution because you don’t have access t
Hi Nate,
Glad to see you trying out the new API.
Well, you're right that the `ProcessFunctionTestHarnesses` doesn't support
the new state API yet. There are operators tailored for async state access,
as well the operator test harness. But unfortunately we can't tell in
advance if a `KeyedProcessF
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 sup
