[jira] [Created] (CARBONDATA-2565) [MV] Join Query Failed with MV data map

[Akash R Nilugal (Jira)]

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)