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 <zhang...@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-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
