Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.1.0
-
None
Description
When I create parquet table with the command below:
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")
It will failed with the error info below:
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
Attachments
Issue Links
- links to