Displaying 1 result from an estimated 1 matches for "inputsplits".
2013 Feb 08
1
ClassNotFoundException when running distributed job using rJava package
...e package in a cluster and executed it, I am getting
ClassNotFoundException. If I run the same job directly without integrating
with R, it runs perfectly.
Here is my R code:
library(rJava)
muMstSpark <- function(mesosMaster = NULL, input = NULL, output = NULL,
scalaLib = NULL, sparkCore = NULL, inputSplits = 8) {
if (is.null(mesosMaster) || is.null(input) || is.null(output) ||
is.null(scalaLib) || is.null(sparkCore)) {
stop("Usage: muMST(<mesosMaster>, <input>, <output>, <scalaLib>,
<sparkCore>, [<inputSplits>]")
}
# Gets the absolute path of t...