[jira] [Created] (SPARK-21644) LocalLimit.maxRows is defined incorrectly

["Reynold Xin (JIRA)" <ji...@apache.org>]

Reynold Xin created SPARK-21644:
-----------------------------------

             Summary: LocalLimit.maxRows is defined incorrectly
                 Key: SPARK-21644
                 URL: https://issues.apache.org/jira/browse/SPARK-21644
             Project: Spark
          Issue Type: Bug
          Components: SQL
    Affects Versions: 2.2.0
            Reporter: Reynold Xin
            Assignee: Reynold Xin


{code}
case class LocalLimit(limitExpr: Expression, child: LogicalPlan) extends UnaryNode {
  override def output: Seq[Attribute] = child.output
  override def maxRows: Option[Long] = {
    limitExpr match {
      case IntegerLiteral(limit) => Some(limit)
      case _ => None
    }
  }
}
{code}

This is simply wrong, since LocalLimit is only about partition level limits.




--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org