Spark no funciona con pureconfig
Estoy tratando de usar pureConfig y configFactory para la configuración de mi aplicación spark. Aquí está mi código:
import pureconfig.{loadConfigOrThrow}
object Source{
def apply(keyName: String, configArguments: Config): Source = {
keyName.toLowerCase match {
case "mysql" =>
val properties = loadConfigOrThrow[DBConnectionProperties](configArguments)
new MysqlSource(None, properties)
case "files" =>
val properties = loadConfigOrThrow[FilesSourceProperties](configArguments)
new Files(properties)
case _ => throw new NoSuchElementException(s"Unknown Source ${keyName.toLowerCase}")
}
}
}
import Source
val config = ConfigFactory.parseString(result.mkString("\n"))
val source = Source("mysql",config.getConfig("source.mysql"))
cuando lo ejecuto desde el IDE (intelliJ) o directamente desde java (es decir, java jar ...) funciona bien.
Pero cuando lo ejecuto con spark-submit falla con el siguiente error:
Exception in thread "main" java.lang.NoSuchMethodError: shapeless.Witness$.mkWitness(Ljava/lang/Object;)Lshapeless/Witness;
De una búsqueda rápida encontré un similar similar a estepregunta. lo que sugiere que la razón de esto se debe al hecho de que spark y pureConfig dependen de Shapeless pero con diferentes versiones,
lo intentésombrearlo como se sugiere en la respuesta
assemblyShadeRules in assembly := Seq(
ShadeRule.rename("shapeless.**" -> "shadeshapless.@1")
.inLibrary("com.github.pureconfig" %% "pureconfig" % "0.7.0").inProject
)
pero no funcionó tan bien, ¿puede ser por una razón diferente? alguna idea de lo que puede funcionar?
Gracias