Skip to content
Permalink
Browse files
Spark 2.x and 3.x version compilation instructions (#6503)
Spark 2.x and 3.x version compilation instructions
  • Loading branch information
hf200012 committed Aug 27, 2021
1 parent 27381fe commit 9191e5b9a9e60a9bba092cf4d19d4cf9dd8c1a34
Showing 1 changed file with 1 addition and 1 deletion.
@@ -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 => {

0 comments on commit 9191e5b

Please sign in to comment.