lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1424] Write Type changed to BULK_INSERT when set ENABLE_ROW_WRITER_OPT_KEY=true (#2289)

Browse Source
This commit is contained in:
pengzhiwei
2020-11-30 23:07:21 +08:00
committed by GitHub
parent 3d5e9fee7f
commit 36ce5bcd92
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
hudi-spark/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala
View File

@@ -120,7 +120,8 @@ private[hudi] object HoodieSparkSqlWriter {
// short-circuit if bulk_insert via row is enabled. // short-circuit if bulk_insert via row is enabled.
// scalastyle:off // 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, val (success, commitTime: common.util.Option[String]) = bulkInsertAsRow(sqlContext, parameters, df, tblName,
basePath, path, instantTime) basePath, path, instantTime)
return (success, commitTime, common.util.Option.empty(), hoodieWriteClient.orNull, tableConfig) return (success, commitTime, common.util.Option.empty(), hoodieWriteClient.orNull, tableConfig)