lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[HUDI-1667]: Fix a null value related bug for spark vectorized reader. (#2636)

Browse Source
This commit is contained in:
Liulietong
2021-03-20 22:54:20 +08:00
committed by GitHub
parent 900de34e45
commit ce3e8ec870
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/hudi/HoodieMergeOnReadRDD.scala
View File

@@ -281,7 +281,7 @@ class HoodieMergeOnReadRDD(@transient sc: SparkContext,
tableState.requiredStructSchema.foreach( tableState.requiredStructSchema.foreach(
f => { f => {
val curPos = posIterator.next() val curPos = posIterator.next()
val curField = row.get(curPos, f.dataType) val curField = if (row.isNullAt(curPos)) null else row.get(curPos, f.dataType)
rowToReturn.update(curIndex, curField) rowToReturn.update(curIndex, curField)
curIndex = curIndex + 1 curIndex = curIndex + 1
} }