> DataStream<> data = input.
> .do()
> .something()
> .fancy();
>
> controlConfigInput.broadcast()
> .connect(data)
> .flatMap(new MyFancyOperatorThatDependsOnConfigStream())
>
> Or slide 36 from here:
> https://www.slideshare.net/dataArtisans/apache-flink-datas
Hi guys:
I have a Flink job which contains multiple pipelines. Each pipeline depends
on some configuration. I want to make the configuration dynamic and
effective after change so I created a data source which periodically poll
the database storing the configuration. However, how can I broadcast th
