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

[Akash R Nilugal (Jira)]

     [ https://issues.apache.org/jira/browse/CARBONDATA-2565?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

xubo245 reassigned CARBONDATA-2565:
-----------------------------------

    Assignee: xubo245

> [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
>            Assignee: xubo245
>            Priority: Major
>
> 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)