Access Flink UI for jobs submitted using Eclipse

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Access Flink UI for jobs submitted using Eclipse

Ritesh Kumar Singh
Hi,

Just a basic question, I am using flink via eclipse but when I execute my jobs, I can't access it via the web dashboard. It's basically a maven project and so I've added all the flink jars in my pom file and I'm executing my code by getting the execution environment as follows:

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(8);
***code***
env.execute();

Although the job runs successfully, I can't access the info via the web dashboard. What part am I doing wrong? 
I also tried installing flink and starting the start-local.sh script. This starts the web dashboard but my flink jobs using eclipse are not getting registered to this web interface. Is there any workaround?

Thanks,
Ritesh
Reply | Threaded
Open this post in threaded view
|

Re: Access Flink UI for jobs submitted using Eclipse

Till Rohrmann

Have you created a RemoteExecutionEnvironment to submit your job from within the IDE to the running cluster? See here [1] for more information.

[1] https://ci.apache.org/projects/flink/flink-docs-master/apis/cluster_execution.html

Cheers,
Till


On Wed, Apr 20, 2016 at 3:41 PM, Ritesh Kumar Singh <[hidden email]> wrote:
Hi,

Just a basic question, I am using flink via eclipse but when I execute my jobs, I can't access it via the web dashboard. It's basically a maven project and so I've added all the flink jars in my pom file and I'm executing my code by getting the execution environment as follows:

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
env.setParallelism(8);
***code***
env.execute();

Although the job runs successfully, I can't access the info via the web dashboard. What part am I doing wrong? 
I also tried installing flink and starting the start-local.sh script. This starts the web dashboard but my flink jobs using eclipse are not getting registered to this web interface. Is there any workaround?

Thanks,
Ritesh