我们目前正在编辑 Spark 中的特定模块。我们正在使用 spark-kernel https://github.com/ibm-et/spark-kernel来运行我们所有的 spark 作业。所以,我们所做的是再次编译我们编辑过的代码。这会生成一个 jar 文件。但是,我们不知道如何将代码指向 jar 文件。
看起来它再次引用了旧脚本,而不是新编辑和新编译的脚本。您对如何修改一些 spark 包/模块并使用 spark-kernel 反映更改有一些想法吗?如果我们不打算使用 spark-kernel,有没有办法可以在 spark 中编辑特定模块,例如 spark 中的 ALS 模块:https ://github.com/apache/spark/blob/master/mllib /src/main/scala/org/apache/spark/ml/recommendation/ALS.scala。谢谢!