chenzhao
Results
2
issues of
chenzhao
//存放flink集群相关的jar包目录 String flinkLibs = "hdfs://hadoopcluster/data/flink/libs"; //用户jar String userJarPath = "hdfs://hadoopcluster/data/flink/user-lib/TopSpeedWindowing.jar"; String flinkDistJar = "hdfs://hadoopcluster/data/flink/libs/flink-yarn_2.11-1.11.0.jar"; 请问SubmitJobApplicationMode类里的这几个路径，flinkLibs里面放的jar包是有哪些？userJarPath 是执行job的上传jar包吗？