Hi,
I have a list (couple of thousands text lines) that I need to use in my map
function. I read this article about broadcasting variables
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/batch/#broadcast-variables>
or
using distributed cache
<https://ci.apache.org/projects/flink/flink-docs-stable/dev/batch/#distributed-cache>
however I need to update this list from time to time, and if I understood
correctly it is not possible on broadcast or cache without restarting the
job. Is there idiomatic way to achieve this? A db seems to be an overkill
for that and I do want to be cheap on io/network calls as much as possible.

Cheers
Avi

Reply via email to