Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/21052#discussion_r183826745
--- Diff:
sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/statsEstimation/FilterEstimation.scala
---
@@ -392,6 +392,10 @@ case class FilterEstimation(plan: Filter) extends
Logging {
val dataType = attr.dataType
var newNdv = ndv
+ if (ndv.toDouble == 0 || colStat.min.isEmpty || colStat.max.isEmpty) {
--- End diff --
Yeah, we need to correct it in the next PR
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
