Spark 2.x and 3.x version compilation instructions (#6503)

Spark 2.x and 3.x version compilation instructions
2021-08-27 10:55:29 +08:00
parent 7235d86331
commit a7b8d110a0
1 changed files with 1 additions and 1 deletions
--- a/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
+++ b/extension/spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
@ -63,7 +63,7 @@ private[sql] class DorisSourceProvider extends DataSourceRegister with RelationP
    val maxRowCount = dorisWriterOption.maxRowCount
    val maxRetryTimes = dorisWriterOption.maxRetryTimes

-    data.foreachPartition(partition => {
+    data.rdd.foreachPartition(partition => {

      val buffer = ListBuffer[String]()
      partition.foreach(row => {