从dataframe到远程thrift服务器创建表

mefy6pfw  于 2021-06-26  发布在  Hive
关注(0)|答案(0)|浏览(178)

我在df1中使用的命令是dataframe,它包含string类型的单个列名。

df1.write.format('jdbc').option('url', 'jdbc:hive2://hostname:port').option('dbtable','sampletest').save()

它会引发以下错误:

Py4JJavaError: An error occurred while calling o146.saveAsTable.
: java.sql.SQLException: org.apache.spark.sql.catalyst.parser.ParseException: 
  no viable alternative at input 'CREATE TABLE sampletest ("Name"'(line 1, pos 25)

我怀疑列名周围的引号会引起问题。需要解决方法或修复的帮助。另外,将sparksession直接连接到远程thrift服务器以触发查询的配置应该是什么?谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题