Reflect review comment

apache · Sep 25, 2019 · 0d9eab9 · 0d9eab9
1 parent c3b59c6
commit 0d9eab9
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/LocalTableScanExec.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/LocalTableScanExec.scala
@@ -37,7 +37,8 @@ case class LocalTableScanExec(
     "numOutputRows" -> SQLMetrics.createMetric(sparkContext, "number of output rows"))
 
   @transient private lazy val unsafeRows: Array[InternalRow] = {
-    if (rows == null || rows.isEmpty) {
+    assert(rows != null)
+    if (rows.isEmpty) {
       Array.empty
     } else {
       val proj = UnsafeProjection.create(output, output)