[jira] [Created] (CARBONDATA-2118) It should throw error when create datamap uses like "as select a as a1,sum(b) from tablename"

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (CARBONDATA-2118) It should throw error when create datamap uses like "as select a as a1,sum(b) from tablename"

Akash R Nilugal (Jira)
xubo245 created CARBONDATA-2118:
-----------------------------------

             Summary: It should  throw error when create datamap uses like "as select a as a1,sum(b) from tablename"
                 Key: CARBONDATA-2118
                 URL: https://issues.apache.org/jira/browse/CARBONDATA-2118
             Project: CarbonData
          Issue Type: Bug
          Components: core, spark-integration
    Affects Versions: 1.3.0
            Reporter: xubo245
            Assignee: xubo245
             Fix For: 1.3.0




        After create datamap  using

{code:java}
 create datamap preagg2 on table PreAggMain using 'preaggregate' as select a as a1,sum(b) from PreAggMain group by a
{code}

it will error when select a1:

{code:java}
    sql("select a1 from PreAggMain_preagg2").show()
{code}

It should  throw error when create datamap.

code:
{code:java}
          test("test pre agg create table 2") {
            sql("create datamap preagg2 on table PreAggMain using 'preaggregate' as select a as a1,sum(b) from PreAggMain group by a")
            checkExistence(sql("DESCRIBE FORMATTED PreAggMain_preagg2"), true, "preaggmain_a")
            checkExistence(sql("DESCRIBE FORMATTED PreAggMain_preagg2"), true, "preaggmain_b_sum")
            checkExistence(sql("DESCRIBE FORMATTED PreAggMain_preagg2"), false, "preaggmain_a1")
            sql("DESCRIBE FORMATTED PreAggMain_preagg2").show()
            sql("select * from PreAggMain_preagg2").show()
            sql("select a1 from PreAggMain_preagg2").show()
       
            sql("DESCRIBE FORMATTED PreAggMain").show()
            sql("select * from PreAggMain").show()
            sql("select a as a1,sum(b) from PreAggMain group by a").show()
       
            sql("drop datamap preagg2 on table PreAggMain")
          }
{code}

error:
        {code:java}
        +------------+----------------+
        |preaggmain_a|preaggmain_b_sum|
        +------------+----------------+
        +------------+----------------+
       
       
        cannot resolve '`a1`' given input columns: [preaggmain_a, preaggmain_b_sum]; line 1 pos 7;
        'Project ['a1]
        +- SubqueryAlias preaggmain_preagg2
           +- Relation[preaggmain_a#101,preaggmain_b_sum#102] CarbonDatasourceHadoopRelation [ Database name :default, Table name :preaggmain_preagg2, Schema :Some(StructType(StructField(preaggmain_a,StringType,true), StructField(preaggmain_b_sum,DoubleType,true))) ]
       
        org.apache.spark.sql.AnalysisException: cannot resolve '`a1`' given input columns: [preaggmain_a, preaggmain_b_sum]; line 1 pos 7;
        'Project ['a1]
        +- SubqueryAlias preaggmain_preagg2
           +- Relation[preaggmain_a#101,preaggmain_b_sum#102] CarbonDatasourceHadoopRelation [ Database name :default, Table name :preaggmain_preagg2, Schema :Some(StructType(StructField(preaggmain_a,StringType,true), StructField(preaggmain_b_sum,DoubleType,true))) ]
       
                at org.apache.spark.sql.catalyst.analysis.package$AnalysisErrorAt.failAnalysis(package.scala:42)
                at org.apache.spark.sql.catalyst.analysis.CheckAnalysis$$anonfun$checkAnalysis$1$$anonfun$apply$2.applyOrElse(CheckAnalysis.scala:88)
                at org.apache.spark.sql.catalyst.analysis.CheckAnalysis$$anonfun$checkAnalysis$1$$anonfun$apply$2.applyOrElse(CheckAnalysis.scala:85)

{code}




--
This message was sent by Atlassian JIRA
(v7.6.3#76005)