我的下面的代码不适用于Spark-submit.
sqlContext.sql(s""" create external 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://....' """)
它给出了错误:
线程“main”中的异常java.lang.RuntimeException:[1.2]失败:“with”预期但找到标识符
此代码适用于Spark-shell,但不适用于Spark-submit.可能是什么原因?