Our Community is getting an upgrade! To get everything ready for the relaunch, we’ll be placing the site in read-only mode starting September 21st.
We really appreciate your understanding while we get things set up behind the scenes. Catch up on all the exciting details about the move here.
Need help or have questions? Drop us a line at [email protected]
Created 02-01-2016 11:14 PM
I am using Spark 1.3.1 to create a hive table from a CSV file (in which the first row is the header row). I have set the hive table property to skip the header row:
TBLPROPERTIES ("skip.header.line.count"="1")
I validated with a "show create table BOP" that the table property is set to ignore the header row. But when i execute "select count(*) from mytable" i get the correct count from HUE/beeswax/beeline, but if i execute the same query via Spark i get a result that is count+1 (i.e. it counts the header row as a data row). Why is Spark reading the hive metadata and still not ignoring the header row?
Created 02-06-2016 12:29 AM
It looks like this may be a bug: https://issues.apache.org/jira/browse/SPARK-11374
Created 02-01-2016 11:18 PM
@Maleeha Qazi have you tried with Spark 1.4.1 in the latest sandbox environment?
Created 02-02-2016 10:12 PM
Here are steps to reproduce in 1.4.1 sandbox. Still getting the issue, too many characters for a comment. Thoughts?
STEPS:
$pyspark
sqlContext.sql("create table names(name string, age int) row format delimited fields terminated by ',' stored as textfile TBLPROPERTIES('skip.header.line.count'='1')")
sqlContext.sql("LOAD DATA INPATH '/user/root/test.txt' overwrite into table names")
sqlContext.sql("Select count(*) from names").show()
3
sqlContext.sql("Select * from names").show()
+-----+-----+
| name| age |
| name| null|
| aaa| 1|
| bbb| 2|hive> select count(*) from names; 2
INPUT FILE: "test.txt", with contents:
name,age aaa,1 bbb,2
Created 02-02-2016 10:22 PM
@azeltov help
Created 02-03-2016 02:17 AM
@vshukla ??
Created 02-03-2016 02:27 AM
Can you please try using HiveContext and report back? @Maleeha Qazi
Created 02-03-2016 05:48 AM
@vshukla I just recreated the scenario @Maleeha Qazi mentioned using a HiveContext in both pyspark, and spark-shell with the sandbox and spark 1.4.1. Still getting the same erroneous output that was mentioned. I created the table using the HiveContext. The show create table looks good in hive. Looks like when spark-sql queries the table, its not handling the header correctly. Not respecting the table property when querying.
Hive is handling the header just fine.
Created 02-06-2016 12:29 AM
It looks like this may be a bug: https://issues.apache.org/jira/browse/SPARK-11374