Hi,
Flink will serialise uses functions when distributing work across the
cluster. Therefore your shared objects will not be shared objects anymore
once your program executes. You will still get object sharing because only
one instance of your function is used to process data on one parallel
instan
Hi there,
I was wondering on how my caching object, would behave in the given scenario
below.
1) I create an instance of an object that performs lookups to an external
resource, and caches results.
2) I have a DataStream that i perform a map function on (with a custom
RichMapFunction)
3) I hav
