Skip to content

Commit 182deef

Browse files
committed
Address a review comment
1 parent 46f1464 commit 182deef

File tree

1 file changed

+8
-4
lines changed

1 file changed

+8
-4
lines changed

sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/util/IntervalUtils.scala

Lines changed: 8 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -288,10 +288,14 @@ object IntervalUtils {
288288
}
289289

290290
private def parseNanos(nanosStr: String, isNegative: Boolean): Long = {
291-
val alignedStr = if (nanosStr == null) nanosStr else (nanosStr + "000000000").substring(0, 9)
292-
val nanos = toLongWithRange("nanosecond", alignedStr, 0L, 999999999L)
293-
val micros = nanos / DateTimeUtils.NANOS_PER_MICROS
294-
if (isNegative) -micros else micros
291+
if (nanosStr != null) {
292+
val alignedStr = (nanosStr + "000000000").substring(0, 9)
293+
val nanos = toLongWithRange("nanosecond", alignedStr, 0L, 999999999L)
294+
val micros = nanos / DateTimeUtils.NANOS_PER_MICROS
295+
if (isNegative) -micros else micros
296+
} else {
297+
0L
298+
}
295299
}
296300

297301
/**

0 commit comments

Comments
 (0)