0

我正在尝试在 MacBook Pro 上运行来自 IntelliJ Idea 的示例 Java/Spark 代码。

我的爪哇：

  12.0.2

另外，我跑过：

  mvn dependency:copy-dependencies

在带有 pom.xml 的文件夹中。

它运作良好。

我的代码：

  SparkConf conf = new SparkConf()
                .setAppName("Word Count").setMaster("local");
  JavaSparkContext sc = new JavaSparkContext(conf);

  JavaDoubleRDD doubleRDD = sc.parallelizeDoubles(Arrays.asList(1.0, 1.0, 2.0, 3.0, 5.0, 8.0));
  JavaRDD<String> stringRDD = sc.parallelize(Arrays.asList("Hello", "World"));
  JavaPairRDD<String, Double> cartesian = stringRDD.cartesian(doubleRDD);
  cartesian.first(); // error!

我收到错误：

   java.lang.IllegalArgumentException

当我对此进行调试时，我发现：

 the source code does not match the bytecode.

我不知道为什么我得到这个。我做错什么了吗 ？或者我错过了一些为 Spark 设置的东西？

谢谢

4

0 回答 0