Github user sadhen commented on a diff in the pull request:
https://github.com/apache/spark/pull/22685#discussion_r224054362
--- Diff:
sql/core/src/main/scala/org/apache/spark/sql/execution/metric/SQLMetrics.scala
---
@@ -95,7 +95,7 @@ object SQLMetrics {
def createMetric(sc: SparkContext, name: String): SQLMetric = {
val acc = new SQLMetric(SUM_METRIC)
- acc.register(sc, name = Some(name), countFailedValues = false)
+ acc.register(sc, name = Some(name))
--- End diff --
duplicated assignment
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
