I am using the scala api for Flink, and am trying to set up a JDBC database connection in my job (on every incoming event I want to query the database to get some data to enrich the event). Because of the serialization and deserialization of the code as it is send from the flink master to the flink workers I cannot just open the connection in my main method. Can someone give me a pointer to the lifecycle methods that are called by the worker to do local initialization of the job? I have not yet been able to find any references or examples of this in the documentation.
Thanks! Best, Bart
