[hudi] branch master updated: [HUDI-1424] Write Type changed to BULK_INSERT when set ENABLE_ROW_WRITER_OPT_KEY=true (#2289)

[leesf]

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

leesf pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 36ce5bc  [HUDI-1424]  Write Type changed to BULK_INSERT when set 
ENABLE_ROW_WRITER_OPT_KEY=true (#2289)
36ce5bc is described below

commit 36ce5bcd92fa6cb2fb88677eae1a7a846f606e3f
Author: pengzhiwei <pengzhiwei2...@icloud.com>
AuthorDate: Mon Nov 30 23:07:21 2020 +0800

    [HUDI-1424]  Write Type changed to BULK_INSERT when set 
ENABLE_ROW_WRITER_OPT_KEY=true (#2289)
---
 hudi-spark/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 c7d5c87..fe0f3f5 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)