Relative Content

Tag Archive for javaapache-spark

Customized readObject and writeObject not work as expected

I want to use guava.BloomFilter in Spark Application. So I need to make BloomFilter serializable by defining a class name SerializableStringBloomFilter which imply Serializable. But according to the log, method readObject and writeObject do not work properly. The value in stage of mapPartitions is normal, but the property bloomFilter is null after reduce stage.