[incubator-doris-spark-connector] 21/50: Spark 2.x and 3.x version compilation instructions (#6503)

[mo...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris-spark-connector.git

commit 9191e5b9a9e60a9bba092cf4d19d4cf9dd8c1a34
Author: jiafeng.zhang <zh...@gmail.com>
AuthorDate: Fri Aug 27 10:55:29 2021 +0800

    Spark 2.x and 3.x version compilation instructions (#6503)
    
    Spark 2.x and 3.x version compilation instructions
---
 src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala b/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
index 774a29c..d8f951b 100644
--- a/src/main/scala/org/apache/doris/spark/sql/DorisSourceProvider.scala
+++ b/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 => {

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org