Yes you have to provide the path of your jar. The reason is: 1. When you start in the pseudo-cluster mode the tasks are started in their own JVM's with their own class loader. 2. You client program has access to your custom operator classes but the remote JVM's don't. Hence you need to ship the JAR file to these remote Task nodes. The getRemoteExcecutionEnvironment() method has overloaded version which takes a JAR file. Just provide your local path to it and it will ship it when it starts
Sameer On Tue, Jul 19, 2016 at 6:51 AM, Biplob Biswas <revolutioni...@gmail.com> wrote: > Hi Sameer, > > Thanks for that quick reply, I was using flink streaming so the program > keeps on running until i close it. But anyway I am ready to try this > getRemoteExecutionEnvironment(), I checked but it ask me for the jar file, > which is weird because I am running the program directly. > > Does it mean I create a jar package and then run it via eclipse? > > If not, could you point me to some resources? > > Thanks > Biplob > > > Sameer W wrote > > From Eclipse it creates a local environment and runs in the IDE. When the > > program finishes so does the Flink execution instance. I have never tried > > accessing the console when the program is running but one the program is > > finished there is nothing to connect to. > > > > If you need to access the dashboard, start Flink in the pseudo-cluster > > mode > > and connect to it using the getRemoteExecutionEnvironment(). That will > > allow you to access the jobs statuses on the dashboard when you finish > > running your job. > > > > Sameer > > > > On Tue, Jul 19, 2016 at 6:35 AM, Biplob Biswas < > > > revolutionisme@ > > > > > > wrote: > > > >> Hi, > >> > >> I am running my flink program using Eclipse and I can't access the > >> dashboard > >> at http://localhost:8081, can someone help me with this? > >> > >> I read that I need to check my flink-conf.yaml, but its a maven project > >> and > >> I don't have a flink-conf. > >> > >> Any help would be really appreciated. > >> > >> Thanks a lot > >> Biplob > >> > >> > >> > >> -- > >> View this message in context: > >> > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-access-Flink-Dashboard-at-8081-running-Flink-program-using-Eclipse-tp8016.html > >> Sent from the Apache Flink User Mailing List archive. mailing list > >> archive > >> at Nabble.com. > >> > > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Can-t-access-Flink-Dashboard-at-8081-running-Flink-program-using-Eclipse-tp8016p8018.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >
