Hi David,
I cannot exactly tell how you ended up seeing an OptionalDataException
without seeing your code.
Flink supports to run multiple jobs on the same cluster. That’s what we
call the session mode.
You should not reuse the ExecutionEnvironment because then, you will create
a single job which
Hello,
I am trying to submit multiple jobs to flink from within my Java program.
I am running into an exception that may be related:
java.io.OptionalDataException.
Should I be able to create multiple plans/jobs within a single session and
execute them concurrently?
If so, is there a working examp
