Hello,

I’m trying to create a table with sqlContext.sql method as below:

val sc = new SparkContext()
val sqlContext = new SQLContext(sc)

import sqlContext.implicits._

sqlContext.sql(s"""
create table if not exists landing (
date string,
referrer string
)
partitioned by (partnerid string,dt string)
row format delimited fields terminated by '\t' lines terminated by '\n'
STORED AS TEXTFILE LOCATION 's3n://...'
      "”")


It gives error on spark-submit:

Exception in thread "main" java.lang.RuntimeException: [2.1] failure: ``with'' 
expected but identifier create found

create external table if not exists landing (

^
        at scala.sys.package$.error(package.scala:27)
        at 
org.apache.spark.sql.catalyst.AbstractSparkSQLParser.parse(AbstractSparkSQLParser.scala:36)
        at 
org.apache.spark.sql.catalyst.DefaultParserDialect.parse(ParserDialect.scala:67)



What can be the reason??

Reply via email to