diff options
author | Shixiong Zhu <shixiong@databricks.com> | 2016-04-06 12:28:04 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2016-04-06 12:28:04 -0700 |
commit | a4ead6d3881f071a2ae53ff1c961c6ac388cac1d (patch) | |
tree | 60e6875acb4485401b6996bb1bbda472a1df98f4 /.github | |
parent | 9c6556c5f8ab013b36312db4bf02c4c6d965a535 (diff) | |
download | spark-a4ead6d3881f071a2ae53ff1c961c6ac388cac1d.tar.gz spark-a4ead6d3881f071a2ae53ff1c961c6ac388cac1d.tar.bz2 spark-a4ead6d3881f071a2ae53ff1c961c6ac388cac1d.zip |
[SPARK-14382][SQL] QueryProgress should be post after committedOffsets is updated
## What changes were proposed in this pull request?
Make sure QueryProgress is post after committedOffsets is updated. If QueryProgress is post before committedOffsets is updated, the listener may see a wrong sinkStatus (created from committedOffsets).
See https://amplab.cs.berkeley.edu/jenkins/job/spark-master-test-maven-hadoop-2.2/644/testReport/junit/org.apache.spark.sql.util/ContinuousQueryListenerSuite/single_listener/ for an example of the failure.
## How was this patch tested?
Existing unit tests.
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #12155 from zsxwing/SPARK-14382.
Diffstat (limited to '.github')
0 files changed, 0 insertions, 0 deletions