Fix compilation

apache · Jun 21, 2019 · 80787ec · 80787ec
1 parent 8ef9f1c
commit 80787ec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala
@@ -208,7 +208,7 @@ trait ProgressReporter extends Logging {
     lastExecution.executedPlan.collect {
       case p if p.isInstanceOf[StateStoreWriter] =>
         val progress = p.asInstanceOf[StateStoreWriter].getProgress()
-        if (hasNewData) progress else progress.copy(newNumRowsUpdated = 0, newNumRowsDiscarded = 0)
+        if (hasNewData) progress else progress.copy(newNumRowsUpdated = 0, newNumLateInputRows = 0)
     }
   }