chenzhao

String configurationDirectory = "/ops/app/flink-1.11.1/conf/"; String flinkLibs = "hdfs://master:8020/flink/libs/libs"; String userJarPath = "hdfs://master:8020/flink/jars/WordCount.jar"; String flinkDistJar = "hdfs://master:8020/flink/libs/flink-yarn_2.11-1.11.0.jar"; 这是我配置的路径代码，程序运行到 yarnClusterDescriptor.deployApplicationCluster 的时候就不动了，flink的running job看不到我的WordCount.jar任务。

> 有什么报错信息吗？ 没有报错，这是我用控制台打印的日志，执行到yarnClusterDescriptor.deployApplicationCluster begin 就不走了，但是jps里面还是可以看到我这个jar在跑。 `try { System.out.println("--------------------------yarnClusterDescriptor.deployApplicationCluster begin--------------------------"); clusterClientProvider = yarnClusterDescriptor.deployApplicationCluster( clusterSpecification, appConfig); System.out.println("--------------------------yarnClusterDescriptor.deployApplicationCluster end--------------------------"); } catch (ClusterDeploymentException e){ e.printStackTrace(); System.out.println("error = "+e.getMessage()); } System.out.println("--------------------------getClusterClient begin--------------------------"); ClusterClient clusterClient =...