If you call createLocalEnvironmentWithWebUI you don't need to start a
cluster with the start-local.sh script,
you can run it from the IDE and it will start the web UI. If you submit
a job to a cluster that was started outside the IDE
you can call getExecutionEnvironment as usual.
Not sure why the errors are different, but the message generally occurs
when you call execute() on an environment
where you never defined any operators on. Please check that you're not
creating multiple environments.
If possible it might also be helpful to provide us (or me personally)
with the code of your program.
On 30.08.2017 19:08, AndreaKinn wrote:
Hi, in the night uninstalling and re-installing maven and flink I solved my
issue.
I started the web dashboard using start-local.sh script and used
/createLocalEnvironmentWithWebUI(new Configuration())/ as you suggested.
Anyway when I start it in eclipse in the ui dashboard no running jobs are
showed (as I expected).
To run it via console with the console command:
/./bin/flink run -c org.apache.flink.quickstart.StreamingJob
target/flink-java-project-0.1.jar/
but an error appears:
/No operators defined in streaming topology. Cannot execute.
/
Strangely, if I execute it in eclipse no errors appear. Do you know which
operators it refers??
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
