1

我正在尝试使用 pySpark 将简单的 spark 数据帧写入 db2 数据库。数据框只有一列,其数据类型为 double。

这是只有一行和一列的数据框: PySpark 数据框

这是数据框架构: PySpark 数据框架构

当我尝试使用以下语法将此数据帧写入 db2 表时:

dataframe.write.mode('overwrite').jdbc(url=url, table=source, properties=prop)

它第一次在数据库中创建表没有任何问题,但是如果我第二次运行代码,它会引发异常: 错误日志

在 DB2 端,列数据类型也是DOUBLE.

不知道我错过了什么。

4

1 回答 1

0

我只是更改了代码中的一小部分,它运行良好。这是我对语法所做的小改动

dataframe.write.jdbc(url=url, table=source, mode = 'overwrite', properties=prop)
于 2018-03-21T17:44:40.523 回答