Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
1.0.0-incubating
-
None
-
spark 1.6.2
Description
I created a carbon table and loaded it with data(csv attached) via spark shell by running the below command from $SPARK_HOME/bin :
./spark-shell
and then to get the carbon context :
import org.apache.spark.sql.CarbonContext;
val cc = new CarbonContext(sc);
CREATE AND LOAD COMMANDS:
scala>cc.sql("CREATE TABLE connectdemo1 (name String, gender String, province String , singler String, age Int) STORED BY 'org.apache.carbondata.format'");
scala>cc.sql("LOAD DATA inpath 'hdfs://localhost:54310/BabuStore/Data/uniqdata/connectdemo1.csv' INTO table connectdemo1 options('DELIMITER'=',','FILEHEADER'='name, gender, province, singler, age')");
The above two operations were successful but when I tried to run the select query, it failed giving me the java.io.FileNotFoundException(see the log attached)
scala> cc.sql("select * from connectdemo1").show();