Re: Regarding Global Configuration in Flink

2016-08-25 Thread Maximilian Michels
Hi! Are you referring to the GlobalConfiguration class? That used to be a singleton class in Flink version < 1.2.x which would load the configuration only once per VM, if it found a config file. It allowed operations that could change that config after it had been loaded. It has since then been re

Regarding Global Configuration in Flink

2016-08-24 Thread Janardhan Reddy
Hi, Is global configuration same for all jobs in a Flink cluster. Is it a good idea to write a custom source which polls some external source every x minutes and updates the global config. Will the config change be propagated across all jobs? What happens when the size of global config grows too