Re: data enrichment via endpoint, serializable issue

Hi Xingcan, option two RichMapFunction works , thanks a lot! Thanks, Steffen > On 19. Jul 2018, at 13:59, Xingcan Cui wrote: > > Hi Steffen, > > You could make the class `TextAPIClient` serializable, or use > `RichMapFunction` [1] and instantiate all the required objects in its > `open()`

Re: data enrichment via endpoint, serializable issue

Hi Steffen, You could make the class `TextAPIClient` serializable, or use `RichMapFunction` [1] and instantiate all the required objects in its `open()` method. [1] https://ci.apache.org/projects/flink/flink-docs-master/dev/api_concepts.html#rich-functions

data enrichment via endpoint, serializable issue

Hi all, I’m new to Apache Flink and I have the following issue: I would like to enrich data via map function. For that I call a method which calls an endpoint but I get following error message „The implementation of the MapFunction is not serializable. The object probably contains or referenc