flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Stefan Richter <s.rich...@data-artisans.com>
Subject Re: Database connection from job
Date Thu, 24 Aug 2017 15:42:27 GMT
Hi,

the lifecycle is described here: https://ci.apache.org/projects/flink/flink-docs-release-1.3/internals/task_lifecycle.html
<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 <flink@kasterma.net>:
> 
> 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


Mime
View raw message