回复:Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown

2015-04-25 Thread doovsaid
Even through grouping by only on name, the issue (CassCastException) still be here. - 原始邮件 发件人:ayan guha 收件人:doovs...@sina.com 抄送人:user 主题:Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown 日期:2015年04月25日 22点33分 Sorry if I am looking at the wrong issue, but your query is

Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown

2015-04-25 Thread ayan guha
Sorry if I am looking at the wrong issue, but your query is wrong.you shoulf group by only on name. On Sat, Apr 25, 2015 at 11:59 PM, wrote: > Hi all, > When I query Postgresql based on Spark SQL like this: > dataFrame.registerTempTable("Employees") > val emps = sqlContext.sq

回复:Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown

2015-04-25 Thread doovsaid
Yeah, same issue. I noticed this issue is not solved yet. - 原始邮件 - 发件人:Ted Yu 收件人:doovs...@sina.com 抄送人:user 主题:Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown 日期:2015年04月25日 22点04分 Looks like this is related: https://issues.apache.org/jira/browse/SPARK-5456 On Sat, Apr

Re: Spark SQL 1.3.1: java.lang.ClassCastException is thrown

2015-04-25 Thread Ted Yu
Looks like this is related: https://issues.apache.org/jira/browse/SPARK-5456 On Sat, Apr 25, 2015 at 6:59 AM, wrote: > Hi all, > When I query Postgresql based on Spark SQL like this: > dataFrame.registerTempTable("Employees") > val emps = sqlContext.sql("select name, sum(salary) from

Spark SQL 1.3.1: java.lang.ClassCastException is thrown

2015-04-25 Thread doovsaid
Hi all, When I query Postgresql based on Spark SQL like this: dataFrame.registerTempTable("Employees") val emps = sqlContext.sql("select name, sum(salary) from Employees group by name, salary") monitor { emps.take(10) .map(row => (row.getString(0), row.getDecima