Babulal created CARBONDATA-2565:
-----------------------------------
Summary: [MV] Join Query Failed with MV data map
Key: CARBONDATA-2565
URL: https://issues.apache.org/jira/browse/CARBONDATA-2565
Project: CarbonData
Issue Type: Bug
Reporter: Babulal
create table mvtest11 (name string,age int,salray int) stored by 'carbondata';
create table mvtest9_1( name_t string,age_t int,salary_t int) stored by
'carbondata';
insert into mvtest11 select 'name1',12,12;
insert into mvtest9_1 select 'name1',12,12;
create datamap mvtest11_mv_2 using 'mv' as select name,sum(salray) from
mvtest11 group by name;
rebuild datamap mvtest11_mv_2
0: jdbc:hive2://10.18.222.231:23040> explain select total from (select name
,sum(salray) as total from mvtest11 group by name) t1 join mvtest9_1 t2 on
t1.name= t2.name_t;
Error: org.apache.spark.sql.AnalysisException: cannot resolve '`t1.total`'
given input columns: [name_t, salary_t, age_t, name, sum(salray)]; line 1 pos
28;
'Project [UDF:preAgg() AS preAgg#6324, 't1.total]
+- Join Inner, (name#5435 = name_t#2595)
:- SubqueryAlias gen_subquery_0
: +- Aggregate [name#5435], [name#5435, sum(cast(salray#5437 as bigint)) AS
sum(salray)#6323L]
: +- SubqueryAlias mvtest11
: +- Relation[name#5435,age#5436,salray#5437] CarbonDatasourceHadoopRelation [
Database name :default, Table name :mvtest11, Schema
:Some(StructType(StructField(name,StringType,true),
StructField(age,IntegerType,true), StructField(salray,IntegerType,true))) ]
+- SubqueryAlias t2
+- SubqueryAlias mvtest9_1
+- Relation[name_t#2595,age_t#2596,salary_t#2597]
CarbonDatasourceHadoopRelation [ Database name :default, Table name :mvtest9_1,
Schema :Some(StructType(StructField(name_t,StringType,true),
StructField(age_t,IntegerType,true), StructField(salary_t,IntegerType,true))) ]
(state=,code=0)
0: jdbc:hive2://10.18.222.231:23040> select t2.* from (select name ,sum(salray)
as total from mvtest11 group by name) t1 join mvtest9_1 t2 on t1.name=
t2.name_t;
+---------+--------+-----------+--+
| name_t | age_t | salary_t |
+---------+--------+-----------+--+
+---------+--------+-----------+--+
No rows selected (12.672 seconds)
0: jdbc:hive2://10.18.222.231:23040> select t1.* from (select name ,sum(salray)
as total from mvtest11 group by name) t1 join mvtest9_1 t2 on t1.name=
t2.name_t;
Error: org.apache.spark.sql.AnalysisException: cannot resolve '`t1.total`'
given input columns: [salary_t, name_t, sum(salray), name, age_t]; line 1 pos
51;
'Project [UDF:preAgg() AS preAgg#6511, name#6512, 't1.total]
+- Join Inner, (name#6512 = name_t#6515)
:- SubqueryAlias gen_subquery_0
: +- Aggregate [name#6512], [name#6512, sum(cast(salray#6514 as bigint)) AS
sum(salray)#6510L]
: +- SubqueryAlias mvtest11
: +- Relation[name#6512,age#6513,salray#6514] CarbonDatasourceHadoopRelation [
Database name :default, Table name :mvtest11, Schema
:Some(StructType(StructField(name,StringType,true),
StructField(age,IntegerType,true), StructField(salray,IntegerType,true))) ]
+- SubqueryAlias t2
+- SubqueryAlias mvtest9_1
+- Relation[name_t#6515,age_t#6516,salary_t#6517]
CarbonDatasourceHadoopRelation [ Database name :default, Table name :mvtest9_1,
Schema :Some(StructType(StructField(name_t,StringType,true),
StructField(age_t,IntegerType,true), StructField(salary_t,IntegerType,true))) ]
(state=,code=0)
0: jdbc:hive2://10.18.222.231:23040>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
