diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2016-06-13 13:44:46 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-06-13 13:44:46 -0700 |
| commit | c654ae2140bc184adb407fd02072b653c5359ee5 (patch) | |
| tree | 9494bc77a4d77c5d2e8388503aebc2477a8d0185 /sql/hive | |
| parent | 5ad4e32d46599ae1b8626f08aa97345d078c28d7 (diff) | |
| download | spark-c654ae2140bc184adb407fd02072b653c5359ee5.tar.gz spark-c654ae2140bc184adb407fd02072b653c5359ee5.tar.bz2 spark-c654ae2140bc184adb407fd02072b653c5359ee5.zip | |
[SPARK-15889][SQL][STREAMING] Add a unique id to ContinuousQuery
## What changes were proposed in this pull request?
ContinuousQueries have names that are unique across all the active ones. However, when queries are rapidly restarted with same name, it causes races conditions with the listener. A listener event from a stopped query can arrive after the query has been restarted, leading to complexities in monitoring infrastructure.
Along with this change, I have also consolidated all the messy code paths to start queries with different sinks.
## How was this patch tested?
Added unit tests, and existing unit tests.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #13613 from tdas/SPARK-15889.
Diffstat (limited to 'sql/hive')
0 files changed, 0 insertions, 0 deletions