Will this work - In main method, serialize config into a string and store it using ParameterTool with key as taskName and value as config (serialized as string). Then in the open method, lookup the relevant configuration using getTaskName().
A follow up to this would be configuring custom windowing functions. I have a size as well as a time based window class where size and time limits are configurable and passed as constructor arguments. How to change this configuration when state persistence/recovery is enabled? A window doesn't have an open method per se -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/