Re: Database connection from job

2017-08-28 Thread Aljoscha Krettek
Hi Bart, I think you might be interested in the (admittedly short) section of the doc about RichFunctions: https://ci.apache.org/projects/flink/flink-docs-release-1.3/dev/api_concepts.html#rich-functions

Re: Database connection from job

2017-08-24 Thread Stefan Richter
Hi, the lifecycle is described here: https://ci.apache.org/projects/flink/flink-docs-release-1.3/internals/task_lifecycle.html Best, Stefan > Am 24.08.2017 um 14:12 schrieb Bart Kastermans : > > I am

Database connection from job

2017-08-24 Thread Bart Kastermans
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 flin