Skip to content

Commit d59bb56

Browse files
committed
Regression detected by changing default spark parallelism.
1 parent 790d75c commit d59bb56

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

core/src/main/scala/org/locationtech/rasterframes/expressions/UnaryRasterAggregate.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -37,10 +37,11 @@ trait UnaryRasterAggregate extends DeclarativeAggregate {
3737
def children = Seq(child)
3838

3939
protected def tileOpAsExpression[R: TypeTag](name: String, op: Tile => R): Expression => ScalaUDF =
40-
udfexpr[R, Any](name, (a: Any) => op(extractTileFromAny(a)))
40+
udfexpr[R, Any](name, (a: Any) => if(a == null) null.asInstanceOf[R] else op(extractTileFromAny(a)))
4141

4242
protected val extractTileFromAny = (a: Any) => a match {
4343
case t: Tile => t
4444
case r: Row => rowTileExtractor(child.dataType)(r)._1
45+
case null => null
4546
}
4647
}

0 commit comments

Comments
 (0)