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) |
Free forum by Nabble | Edit this page |