It is my mistake, some how I have added the io.compression.codec property value
as the above mentioned class. Resolved the problem now
Thanks and Regards,
Sankar S.
On Wednesday, 27 August 2014, 1:23, S Malligarjunan
wrote:
Hello all,
I have just checked out branch-1.1
and executed
Hello all,
I have just checked out branch-1.1
and executed below command
./bin/spark-shell --driver-memory 1G
val hiveContext = new org.apache.spark.sql.hive.HiveContext(sc)
val hiveContext = new org.apache.spark.sql.hive.HiveContext(sc)
hiveContext.hql("CREATE TABLE IF NOT EXISTS src (key INT,