Hi,
I'm working on the problem of remotely submitting apps to the spark
master. I'm trying to use the spark-jobserver project
(https://github.com/ooyala/spark-jobserver) for that purpose.
For scala apps looks like things are working smoothly, but for java
apps, I have an issue with implementing the scala trait "SparkJob" in
java. Specifically, I'm trying to implement the "validate" method like
this:
@Override
public SparkJobValidation validate(SparkContext sc, Config conf) {
return new SparkJobValid();
}
I'm getting the following compilation error:
Type mismatch: cannot convert from SparkJobValid to SparkJobValidation
Would love for some advice / working example.
Thanks,
Tomer
---------------------------------------------------------------------
To unsubscribe, e-mail: user-unsubscr...@spark.apache.org
For additional commands, e-mail: user-h...@spark.apache.org
