Hi, When I did
sc.sequenceFile(file, classOf[Text], classOf[Text]).flatMap(map_func).count() It gave me result of 365. However, when I did sc.sequenceFile(file, classOf[Text], classOf[Text]).flatMap(map_func).sortByKey().count(), It threw java.io.NotSerializableException for Key Class returned by flapMap. My question is Why does sortByKey require the Key/Value Classes to be Serialized.? Thanks and Regards, Archit Thakur.
