[ https://issues.apache.org/jira/browse/CARBONDATA-734?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yadong Qi updated CARBONDATA-734: --------------------------------- Description: When I create parquet table with the command below: {code} import org.apache.spark.sql.SparkSession import org.apache.spark.sql.CarbonSession._ val carbon = SparkSession.builder().config(sc.getConf).getOrCreateCarbonSession("hdfs://100.0.0.4:9000/user/hive/warehouse/carbon.store") carbon.sql("create table src(key int, value string) stored as parquet") {code} It will failed with the error info below: {code} java.lang.RuntimeException: [1.1] failure: identifier matching regex (?i)ALTER expected create table src(key int, value string) stored as parquet ^ at scala.sys.package$.error(package.scala:27) at org.apache.spark.sql.parser.CarbonSpark2SqlParser.parse(CarbonSpark2SqlParser.scala:45) at org.apache.spark.sql.parser.CarbonSparkSqlParser.parsePlan(CarbonSparkSqlParser.scala:51) at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592) ... 50 elided {code} was: When I create parquet table using the below command: {code} import org.apache.spark.sql.SparkSession import org.apache.spark.sql.CarbonSession._ val carbon = SparkSession.builder().config(sc.getConf).getOrCreateCarbonSession("hdfs://100.0.0.4:9000/user/hive/warehouse/carbon.store") carbon.sql("create table src(key int, value string) stored as parquet") {code} It will failed with the error info below: {code} java.lang.RuntimeException: [1.1] failure: identifier matching regex (?i)ALTER expected create table src(key int, value string) stored as parquet ^ at scala.sys.package$.error(package.scala:27) at org.apache.spark.sql.parser.CarbonSpark2SqlParser.parse(CarbonSpark2SqlParser.scala:45) at org.apache.spark.sql.parser.CarbonSparkSqlParser.parsePlan(CarbonSparkSqlParser.scala:51) at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592) ... 50 elided {code} > Can't create parquet/orc table with CarbonSession > ------------------------------------------------- > > Key: CARBONDATA-734 > URL: https://issues.apache.org/jira/browse/CARBONDATA-734 > Project: CarbonData > Issue Type: Bug > Components: spark-integration > Affects Versions: 1.1.0-incubating > Reporter: Yadong Qi > > When I create parquet table with the command below: > {code} > import org.apache.spark.sql.SparkSession > import org.apache.spark.sql.CarbonSession._ > val carbon = SparkSession.builder().config(sc.getConf).getOrCreateCarbonSession("hdfs://100.0.0.4:9000/user/hive/warehouse/carbon.store") > carbon.sql("create table src(key int, value string) stored as parquet") > {code} > It will failed with the error info below: > {code} > java.lang.RuntimeException: [1.1] failure: identifier matching regex (?i)ALTER expected > create table src(key int, value string) stored as parquet > ^ > at scala.sys.package$.error(package.scala:27) > at org.apache.spark.sql.parser.CarbonSpark2SqlParser.parse(CarbonSpark2SqlParser.scala:45) > at org.apache.spark.sql.parser.CarbonSparkSqlParser.parsePlan(CarbonSparkSqlParser.scala:51) > at org.apache.spark.sql.SparkSession.sql(SparkSession.scala:592) > ... 50 elided > {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346) |
Free forum by Nabble | Edit this page |