-
- Downloads
[SPARK-21597][SS] Fix a potential overflow issue in EventTimeStats
## What changes were proposed in this pull request? This PR fixed a potential overflow issue in EventTimeStats. ## How was this patch tested? The new unit tests Author: Shixiong Zhu <shixiong@databricks.com> Closes #18803 from zsxwing/avg.
Showing
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/EventTimeWatermarkExec.scala 4 additions, 6 deletions...park/sql/execution/streaming/EventTimeWatermarkExec.scala
- sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/ProgressReporter.scala 1 addition, 1 deletion...ache/spark/sql/execution/streaming/ProgressReporter.scala
- sql/core/src/test/scala/org/apache/spark/sql/streaming/EventTimeWatermarkSuite.scala 39 additions, 2 deletions.../apache/spark/sql/streaming/EventTimeWatermarkSuite.scala
Loading
Please register or sign in to comment