Aah, thanks a lot for that insight. Pretty new to the Flink systems and
learning on my own so prone to making mistakes.
Thanks a lot for helping.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Reading-Parameter-values-sent-to-partition-tp7
There are 2 flaws in your code:
Let's start with the fundamental one:
At no point do you associate your mapConf with the flatMap or even the job.
THeoretically you should add it to the flatMap using
flatMap(...).withConfiguration(mapConf) method.
But here's is the second a more subtle flaw:
