oops

hvanhovell · hvanhovell · commit 8ab093125272 · 2018-04-10T23:26:09.000+02:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/expressions/codegen/CodeGenerator.scala
@@ -333,7 +333,7 @@ class CodegenContext {
       case _: StructType | _: ArrayType | _: MapType => s"$value = $initCode.copy();"
       case _ => s"$value = $initCode;"
     }
-    ExprCode.forNonNullValue(JavaCode.global(value, dataType))
+    ExprCode(code, FalseLiteral, JavaCode.global(value, dataType))
   }
 
   def declareMutableStates(): String = {

Original file line number	Diff line number	Diff line change
`@@ -333,7 +333,7 @@ class CodegenContext {`
`333`	`333`	`case _: StructType \| _: ArrayType \| _: MapType => s"$value = $initCode.copy();"`
`334`	`334`	`case _ => s"$value = $initCode;"`
`335`	`335`	`}`
`336`		`- ExprCode.forNonNullValue(JavaCode.global(value, dataType))`
	`336`	`+ ExprCode(code, FalseLiteral, JavaCode.global(value, dataType))`
`337`	`337`	`}`
`338`	`338`
`339`	`339`	`def declareMutableStates(): String = {`