scala - Spark 零字节使用 SQLServerBulkCopy 编写

Question

我正在尝试使用 com.microsoft.sqlserver.jdbc.SQLServerBulkCopy 将数据框保存到 sql 数据库中。代码完成了工作并将一些行插入到我的表中，但是当我查看 OutputMetric.BytesWritten 时，该值为 0。我错过了什么吗？

  val fileRecord = new SQLServerBulkDataFrameFileRecord(iterator, bulkCopyMetadata)
  val sqlServerBulkCopy = new SQLServerBulkCopy(connection)
  sqlServerBulkCopy.setDestinationTableName(dbTable)
  sqlServerBulkCopy.setBulkCopyOptions(BulkCopyUtils.getBulkCopyOptions(config))
  sqlServerBulkCopy.writeToServer(fileRecord)

阶段结果

任务结果

标签： scalaapache-sparkapache-spark-sql