|
|
Can Flink attach multiple jobs to Stream local envirnoment with Web Ui by java code?
my code is like this
env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(config);
env.addSource(...);
env.addSink(...);
env.execute("stream job1");
What I would like to do is to loop through this and attach job2 job3 to the same environment with web ui managment. How can this be done in java code?
I tried to use env2 = StreamExecutionEnvironment.getExecutionEnvironment(),
but it seems like the new job2 is not attatch to env I created before.
please help me thanks in advance
|
Locked
