Hi jjz
Please try to use english to describe questions in future.
Please provide two table schema through executing the below statement, and
sent the query result to us
cc.sql("select * from jjz_table1").show(50)
cc.sql("select * from jjz_table2").show(50)
Regards
Liang
2016-07-01 15:39 GMT+05:30 籍九洲 <[email protected]>:
> 我建立两张表jjz_table1 ，jjz_table12
> cc.sql("create table if not exists jjz_table1 (id Int, name string, city
> string, age Int) STORED BY 'org.apache.carbondata.format'")
> cc.sql("select a.id,a.name,a.age,a.city from jjz_table1 a join
> jjz_table2 b on a.name=b.name and a.age=b.age").show(50)
> 执行这个报错Caused by: java.lang.ClassCastException
> 但是运行cc.sql("select a.name,a.age,a.city from jjz_table1 a join jjz_table2
> b on a.name=b.name and a.age=b.age").show(50)却可以正常运行
> +-----+----+----+
> | name| age|city|
> +-----+----+----+
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|21.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> |aaaaa|31.0| 上海市|
> +-----+----+----+
> only showing top 50 rows
> 这是bug吗？
--
Regards
Liang
