Re: Unit testing KeyedProcessFunction that uses async state

2025-06-23 Thread Lasse Nedergaard
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

Re: Enrichment with keyed state as cache

2025-06-23 Thread Gabor Somogyi
Hi Nate, I'm afraid we're in a situation where there is no off the shelf solution. An AsyncLookupFunction can be manually implemented based on AbstractRichFunction which does the aync lookup. The tricky part is to fire threads for lookup and process result in mailbox thread because state access i

Enrichment with keyed state as cache

2025-06-23 Thread Nate Drake
Hi, We're building a Flink job to process metric data from client devices. We need to enrich these events via an external HTTP API. We were thinking we'd use Flink state as a cache of this enrichment data to reduce the load on the external service. It seems AsyncFunctions do not support keyed st