flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Chesnay Schepler <ches...@apache.org>
Subject Re: datastream.print() doesn't works
Date Thu, 31 Aug 2017 11:33:14 GMT
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/
>


Mime
View raw message