??????????flink on yarn???????????????? flink run -m yarn-cluster ./examples/batch/WordCount.jar ?????????????? ------------------------------------------------------------ The program finished with the following exception:
org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: org.apache.flink.runtime.rest.util.RestClientException: [org.apache.flink.runtime.rest.handler.RestHandlerException: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (397a081a0313f462818575fc725b3582) at org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler.propagateException(JobExecutionResultHandler.java:94) at org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler.lambda$handleRequest$1(JobExecutionResultHandler.java:84) at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870) ... ?????????????????????????????????????????? #=============================================================================== high-availability: zookeeper high-availability.storageDir: hdfs://mycluster/flink/ha/ high-availability.zookeeper.quorum: hadoop201:2181,hadoop202:2181,hadoop203:2181 high-availability.zookeeper.path.root: /flink high-availability.cluster-id: /default_one # important: customize per cluster #????ck?????????? state.backend: filesystem state.checkpoints.dir: hdfs://mycluster/flink/checkpoints #??????????savepoint?????????? state.savepoints.dir: hdfs://mycluster/flink/savepoints # ???????????????? jobmanager.archive.fs.dir: hdfs://mycluster/flink/completed-jobs/ historyserver.archive.fs.dir: hdfs://mycluster/flink/completed-jobs/ #=============================================================================== ??????
