The problem is that the Web UI hasn't started at all Im using the sane config file that i used for none flip-6 is that ok ? Also i got this error in the logs .
2018-04-24 10:16:05,466 ERROR > org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Could not > recover the job graph for 4ac6ed0270bf6836941285ffcb9eb9c6. > java.lang.IllegalStateException: Not running. Forgot to call start()? > at > org.apache.flink.util.Preconditions.checkState(Preconditions.java:195) > at > org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.verifyIsRunning(ZooKeeperSubmittedJobGraphStore.java:411) > at > org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.recoverJobGraph(ZooKeeperSubmittedJobGraphStore.java:167) > at > org.apache.flink.runtime.dispatcher.Dispatcher.lambda$recoverJobs$3(Dispatcher.java:445) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) > at > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415) > at > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > 2018-04-24 10:16:05,469 ERROR > org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Could not > recover the job graph for 700f37540fe95787510dfa2bc0cc5ac3. > java.lang.IllegalStateException: Not running. Forgot to call start()? > at > org.apache.flink.util.Preconditions.checkState(Preconditions.java:195) > at > org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.verifyIsRunning(ZooKeeperSubmittedJobGraphStore.java:411) > at > org.apache.flink.runtime.jobmanager.ZooKeeperSubmittedJobGraphStore.recoverJobGraph(ZooKeeperSubmittedJobGraphStore.java:167) > at > org.apache.flink.runtime.dispatcher.Dispatcher.lambda$recoverJobs$3(Dispatcher.java:445) > at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:39) > at > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:415) > at > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) On Tue, Apr 24, 2018 at 10:06 AM, Gary Yao <g...@data-artisans.com> wrote: > Hi Miki, > > IIRC the port on which the Web UI is listening is not allocated > dynamically when > deploying on Mesos, and should be 8081 by default (you can override the > default > by setting rest.port in flink-conf.yaml). If you can find out the > hostname/IP of > the JobManager, you can submit as usual via the Web UI. Alternatively you > can > use the CLI, e.g., > > bin/flink run -m hostname:6123 examples/streaming/WordCount.jar > > where 6123 is the jobmanager.rpc.port. > > Let me know if any of these work for you > > Best, > Gary > > > On Tue, Apr 24, 2018 at 8:55 AM, miki haiat <miko5...@gmail.com> wrote: > >> NO :) ... >> I usually using the web UI . >> Can you refer me to some example how to submit a job ? >> Using REST ? to which port ? >> >> thanks, >> >> miki >> >> On Tue, Apr 24, 2018 at 9:42 AM, Gary Yao <g...@data-artisans.com> wrote: >> >>> Hi Miki, >>> >>> Did you try to submit a job? With the introduction of FLIP-6, resources >>> are >>> allocated dynamically. >>> >>> Best, >>> Gary >>> >>> >>> On Tue, Apr 24, 2018 at 8:31 AM, miki haiat <miko5...@gmail.com> wrote: >>> >>>> >>>> HI, >>>> Im trying to tun flip-6 on mesos but its not clear to me what is the >>>> correct way to do it . >>>> >>>> I run the session script and i can see that new framework has been >>>> created in mesos but the task manager hasn't been created >>>> running taskmanager-flip6.sh throw null pointer ... >>>> >>>> what is the correct way to run flip-6 . >>>> >>>> >>>> thanks, >>>> >>>> miki >>>> >>> >>> >> >
