Displaying 1 result from an estimated 1 matches for "sparkcore".
Did you mean:
spamscore
2013 Feb 08
1
ClassNotFoundException when running distributed job using rJava package
...when I deployed
the 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 th...