Streaming.conf 只是将传递给驱动程序的字符串。你的司机一定能看见。最简单的方法是将其放置在一个可访问的位置，指定您希望通过将其下载到沙盒中 spark.mesos.uris [1]. 您也可以编写应用程序来支持从远程位置进行读取，只需在cli上传递该位置即可。 --files 用于在执行器中放置文件，但您正试图将文件传递给驱动程序，因此无法工作。
[1] http://spark.apache.org/docs/latest/running-on-mesos.html
迈克尔·甘梅尔特
中层

下面是您应该启动的命令示例，以便使其正常工作： dcos spark run --submit-args='--conf spark.mesos.uris=https://s3-us-west-2.amazonaws.com/andrey-so-36323287/pi.conf --class JavaSparkPiConf https://s3-us-west-2.amazonaws.com/andrey-so-36323287/sparkPi_without_config_file.jar /mnt/mesos/sandbox/pi.conf' 哪里 --conf spark.mesos.uris=... mesos启动驱动程序或执行程序时，要下载到沙盒中的uri的逗号分隔列表。这适用于粗粒度和细粒度模式。 /mnt/mesos/sandbox/pi.conf 主类作为第0个参数接收的下载文件的路径（请参见下面的代码段）。 /mnt/mesos/sandbox/ 是容器内的标准路径，该容器Map到共同响应的mesos任务沙盒。

public final class JavaSparkPiConf {

  public static void main(String[] args) throws Exception {
    SparkConf sparkConf = new SparkConf().setAppName("JavaSparkPi");
    JavaSparkContext jsc = new JavaSparkContext(sparkConf);

    Scanner scanner = new Scanner(new FileInputStream(args[0]));
    int slices;
    if (scanner.hasNextInt()) {
      slices = scanner.nextInt();
    } else {
      slices = 2;
    }
    int n = 100000 * slices;
    List<Integer> l = new ArrayList<>(n);
    for (int i = 0; i < n; i++) {
      l.add(i);
    }

    JavaRDD<Integer> dataSet = jsc.parallelize(l, slices);

    int count = dataSet.map(new Function<Integer, Integer>() {
      @Override
      public Integer call(Integer integer) {
        double x = Math.random() * 2 - 1;
        double y = Math.random() * 2 - 1;
        return (x * x + y * y < 1) ? 1 : 0;
      }
    }).reduce(new Function2<Integer, Integer, Integer>() {
      @Override
      public Integer call(Integer integer, Integer integer2) {
        return integer + integer2;
      }
    });

    System.out.println("Pi is roughly " + 4.0 * count / n);

    jsc.stop();
  }
}