diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-03-08 23:23:10 -0800 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2017-03-08 23:23:10 -0800 |
| commit | eeb1d6db878641d9eac62d0869a90fe80c1f4461 (patch) | |
| tree | 5738191de87c5f212c7033a3dbac85153474aed3 /sql/hive | |
| parent | 029e40b412e332c9f0fff283d604e203066c78c0 (diff) | |
| download | spark-eeb1d6db878641d9eac62d0869a90fe80c1f4461.tar.gz spark-eeb1d6db878641d9eac62d0869a90fe80c1f4461.tar.bz2 spark-eeb1d6db878641d9eac62d0869a90fe80c1f4461.zip | |
[SPARK-19859][SS][FOLLOW-UP] The new watermark should override the old one.
## What changes were proposed in this pull request?
A follow up to SPARK-19859:
- extract the calculation of `delayMs` and reuse it.
- update EventTimeWatermarkExec
- use the correct `delayMs` in EventTimeWatermark
## How was this patch tested?
Jenkins.
Author: uncleGen <hustyugm@gmail.com>
Closes #17221 from uncleGen/SPARK-19859.
Diffstat (limited to 'sql/hive')
0 files changed, 0 insertions, 0 deletions