This is an automated email from the ASF dual-hosted git repository.
gurwls223 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git.
from e9145d4 [SPARK-31986][SQL] Fix Julian-Gregorian micros rebasing of
overlapping local timestamps
add fe68e95 [SPARK-24634][SS][FOLLOWUP] Rename the variable from
"numLateInputs" to "numRowsDroppedByWatermark"
No new revisions were added by this update.
Summary of changes:
docs/structured-streaming-programming-guide.md | 9 ++++-----
.../sql/execution/streaming/ProgressReporter.scala | 6 +++++-
.../execution/streaming/statefulOperators.scala | 14 ++++++-------
.../org/apache/spark/sql/streaming/progress.scala | 10 +++++-----
.../sql/streaming/EventTimeWatermarkSuite.scala | 16 ++++++++-------
.../sql/streaming/StateStoreMetricsTest.scala | 23 +++++++++++++---------
.../streaming/StreamingDeduplicationSuite.scala | 11 ++++++-----
.../spark/sql/streaming/StreamingJoinSuite.scala | 10 +++++-----
.../StreamingQueryStatusAndProgressSuite.scala | 8 ++++----
9 files changed, 59 insertions(+), 48 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org
