Re: Spark RuntimeException due to Unsupported datatype NullType

2014-08-19 Thread Yin Huai
: Hi, *Spark RuntimeException due to Unsupported datatype NullType , *When saving null primitives *jsonRDD *with *.saveAsParquetFile()* *Code: I am trying to* store jsonRDD into Parquet file using *saveAsParquetFile with below code.* JavaRDDString javaRDD = ssc.sparkContext().parallelize

Spark RuntimeException due to Unsupported datatype NullType

2014-08-11 Thread rafeeq s
Hi, *Spark RuntimeException due to Unsupported datatype NullType , *When saving null primitives *jsonRDD *with *.saveAsParquetFile()* *Code: I am trying to* store jsonRDD into Parquet file using *saveAsParquetFile with below code.* JavaRDDString javaRDD = ssc.sparkContext().parallelize(jsonData