Can't zip RDDs with unequal numbers of partitions

1. java.lang.IllegalArgumentException: Can't zip RDDs with unequal numbers of partitions
2. //如果两个RDD分区数不同，则抛出异常

http://lxw1234.com/archives/2015/07/350.htm

 

java.lang.NullPointerException: Expected timestamp in the Flume event headers, but it was null