java - Spark's serialization -
i have own .jar , want .jar deployed spark. got have problems new code in "numberformat" , "locale" java clasess used global variables:
private numberformat machinelocale private locale locale
if include new code , try deploy in spark following error:
caused by: org.apache.spark.sparkexception: job aborted due stage failure: task 1 in stage 1.0 failed 4 times, recent failure: lost task 1.3 in stage 1.0 (tid 9, sparkslave4.local): java.io.ioexception: com.esotericsoftware.kryo.kryoexception: error during java deserialization.
serialization trace: locale (java.text.decimalformatsymbols) symbols (java.text.decimalformat) numberformat
please, can give me clue? how have deal these classes? lot
Comments
Post a Comment