dfStage01.write.mode("append").insertInto("temp.acct_stage_01")以上语句在 spark-shell 中跑没有问题,但是build成jar 后,用spaek-submit运行报以下错误:
Exception in thread "main" org.apache.spark.sql.AnalysisException: Specifying database name or other qualifiers are not allowed for temporary tables. If the table name has dots (.) in it, please quote the table name with backticks (`).;这个应该怎么办?谢谢
Exception in thread "main" org.apache.spark.sql.AnalysisException: Specifying database name or other qualifiers are not allowed for temporary tables. If the table name has dots (.) in it, please quote the table name with backticks (`).;这个应该怎么办?谢谢
解决方案 »
- 执行cinder-volume时,提示AMQP server on localhost:5672 is unreachable: Socket closed
- hadoop MR结果文件重命令
- 分享:关于享用AWS免费午餐的一些补充
- spark批量插入hbase
- AWS 安装好nginx后,无法用Amazon 给的公用DNS,IP 访问?
- 现在那个运服务器比较不错一些呢
- 求助:AWS S3 管理控制台上传文件问题
- scala开发插件匹配
- spark sql 执行完毕后,落地小文件太多
- 讨论: 关于广播变量的用法
- RowMatrix 的转置怎么处理。
- docker pull image失败 非网络原因
dfStage01.registerTempTable("table1")
sql("insert into temp.acct_stage_01 select * from table1")这样试试