Hi Peter,
this kind of use case is supported, but it is best practice to split
independent pipelines into individual jobs.
One reason for that is to isolate failures and restarts.
For example, I would split the program you posted into two programs, one
for the "foo" topic and one of the "bar"
Hello Flink People :-)
I am trying to get my head around flink - is it a supported use case to
register multiple streams with possibly more than one transformation / action
per stream?
def main(args: Array[String]): Unit = {
val env = StreamExecutionEnvironment.getExecutionEnvironment
