java - SparkException: local class incompatible -
i'm trying submit spark job client cloudera cluster. in cluster using cdh-5.3.2 , spark version 1.2.0 , hadoop version 2.5.0 . test our cluster submitting wordcount sample taken spark web site. can submit our spark job written in java. however, cannot write our result file on hdfs . got following error, 20/06/25 09:38:16 info dagscheduler: job 0 failed: saveastextfile @ simplewordcount.java:36, took 5.450531 s exception in thread "main" 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 8, obelix2): java.io.invalidclassexception: org.apache.spark.rdd.pairrddfunctions; local class incompatible: stream classdesc serialversionuid = 8789839749593513237, local class serialversionuid = -4145741279224749316 @ java.io.objectstreamclass.initnonproxy(objectstreamclass.java:617) @ java.io.objectinputstream.readnonproxydesc(objectinputstream.java:1622) @ java.io.object...