HiI have updated to Flink 2.1 and I can see the changes you mention. I hope you can help me here as I can’t see how to use the new functions. I’m implementing TwoInputNoneBroadcastEventTimeStreamProcesaFunction. And I can’t figure out how to get testharness to work on interfaces like this. So any h
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
