From 36ce5bcd92fa6cb2fb88677eae1a7a846f606e3f Mon Sep 17 00:00:00 2001 From: pengzhiwei Date: Mon, 30 Nov 2020 23:07:21 +0800 Subject: [PATCH] [HUDI-1424] Write Type changed to BULK_INSERT when set ENABLE_ROW_WRITER_OPT_KEY=true (#2289) --- .../src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala b/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala index c7d5c8782..fe0f3f5e4 100644 --- a/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala +++ b/hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala @@ -120,7 +120,8 @@ private[hudi] object HoodieSparkSqlWriter { // short-circuit if bulk_insert via row is enabled. // scalastyle:off - if (parameters(ENABLE_ROW_WRITER_OPT_KEY).toBoolean) { + if (parameters(ENABLE_ROW_WRITER_OPT_KEY).toBoolean && + operation == WriteOperationType.BULK_INSERT) { val (success, commitTime: common.util.Option[String]) = bulkInsertAsRow(sqlContext, parameters, df, tblName, basePath, path, instantTime) return (success, commitTime, common.util.Option.empty(), hoodieWriteClient.orNull, tableConfig)