Create new datastream dynamically in Flink

Question

I am trying to create new datastreams out of one raw datastream based on certain rules available in database. Once I start the Flink job and after some, if I need to create a new datastream as per updated entries in database, how can I achieve that. So here I do not want to restart the Flink job but to create new datastream dynamically at runtime and add it to the execution DAG.

Answer 1

Short answer: this is not possible at runtime.

You need to stop the job and submit a new job.