我在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服务器以触发查询的配置应该是什么?谢谢。
暂无答案!
目前还没有任何答案,快来回答吧!