Uh oh!
There was an error while loading. Please reload this page.
[SPARK-19674][SQL]Ignore driver accumulator updates don't belong to the execution when merging all accumulator updates - #17009
Conversation
carsonwang
commented
Feb 21, 2017
SparkQA
commented
Feb 21, 2017
Test build #73199 has finished for PR 17009 at commit
|
| checkAnswer(listener.getExecutionMetrics(0), accumulatorUpdates.mapValues(_ * 2)) | ||
| // Non-existing driver accumulator updates should be filtered and no exception will be thrown. |
There was a problem hiding this comment.
I was doing some own experiments that adds physical operators at runtime. The metrics of the added operators are not registered to the execution so I got a NoSuchElementException.
The change looks reasonable, but is it |
carsonwang
commented
Feb 23, 2017
Thanks @cloud-fan . |
SparkQA
commented
Feb 23, 2017
Test build #73333 has finished for PR 17009 at commit
|
cloud-fan
commented
Feb 23, 2017
retest this please |
SparkQA
commented
Feb 23, 2017
Test build #73360 has finished for PR 17009 at commit
|
cloud-fan
commented
Feb 23, 2017
thanks, merging to master! |
…the execution when merging all accumulator updates ## What changes were proposed in this pull request? In SQLListener.getExecutionMetrics, driver accumulator updates don't belong to the execution should be ignored when merging all accumulator updates to prevent NoSuchElementException. ## How was this patch tested? Updated unit test. Author: Carson Wang <carson.wang@intel.com> Closesapache#17009 from carsonwang/FixSQLMetrics.
mallman
commented
Mar 24, 2017
It looks like this will fix a bug we're experiencing in Spark 2.1. Given that this PR is a bug fix, any chance we can get a backport into |
…the execution when merging all accumulator updates ## What changes were proposed in this pull request? In SQLListener.getExecutionMetrics, driver accumulator updates don't belong to the execution should be ignored when merging all accumulator updates to prevent NoSuchElementException. ## How was this patch tested? Updated unit test. Author: Carson Wang <carson.wang@intel.com> Closesapache#17009 from carsonwang/FixSQLMetrics.
mallman
commented
Mar 24, 2017
I created a Spark 2.1 backport at #17418. |
[SPARK-19674][SQL] Ignore driver accumulator updates don't belong to the execution when merging all accumulator updates N.B. This is a backport to branch-2.1 of #17009. ## What changes were proposed in this pull request? In SQLListener.getExecutionMetrics, driver accumulator updates don't belong to the execution should be ignored when merging all accumulator updates to prevent NoSuchElementException. ## How was this patch tested? Updated unit test. Author: Carson Wang <carson.wangintel.com> Author: Carson Wang <carson.wang@intel.com> Closes#17418 from mallman/spark-19674-backport_2.1.
What changes were proposed in this pull request?
In SQLListener.getExecutionMetrics, driver accumulator updates don't belong to the execution should be ignored when merging all accumulator updates to prevent NoSuchElementException.
How was this patch tested?
Updated unit test.