[ https://issues.apache.org/jira/browse/SPARK-15832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Apache Spark reassigned SPARK-15832: ------------------------------------ Assignee: Apache Spark > Embedded IN/EXISTS predicate subquery throws TreeNodeException > -------------------------------------------------------------- > > Key: SPARK-15832 > URL: https://issues.apache.org/jira/browse/SPARK-15832 > Project: Spark > Issue Type: Bug > Affects Versions: 2.0.0 > Reporter: Ioana Delaney > Assignee: Apache Spark > Priority: Minor > > Queries with embedded existential sub-query predicates throws exception when > building the physical plan. > Example failing query: > {code} > scala> Seq((1, 1), (2, 2)).toDF("c1", "c2").createOrReplaceTempView("t1") > scala> Seq((1, 1), (2, 2)).toDF("c1", "c2").createOrReplaceTempView("t2") > scala> sql("select c1 from t1 where (case when c2 in (select c2 from t2) then > 2 else 3 end) IN (select c2 from t1)").show() > Binding attribute, tree: c2#239 > org.apache.spark.sql.catalyst.errors.package$TreeNodeException: Binding > attribute, tree: c2#239 > at > org.apache.spark.sql.catalyst.errors.package$.attachTree(package.scala:50) > at > org.apache.spark.sql.catalyst.expressions.BindReferences$$anonfun$bindReference$1.applyOrElse(BoundAttribute.scala:88) > ... > at > org.apache.spark.sql.catalyst.expressions.BindReferences$.bindReference(BoundAttribute.scala:87) > at > org.apache.spark.sql.execution.joins.HashJoin$$anonfun$4.apply(HashJoin.scala:66) > at > org.apache.spark.sql.execution.joins.HashJoin$$anonfun$4.apply(HashJoin.scala:66) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) > at > scala.collection.TraversableLike$$anonfun$map$1.apply(TraversableLike.scala:234) > at scala.collection.immutable.List.foreach(List.scala:381) > at scala.collection.TraversableLike$class.map(TraversableLike.scala:234) > at scala.collection.immutable.List.map(List.scala:285) > at > org.apache.spark.sql.execution.joins.HashJoin$class.org$apache$spark$sql$execution$joins$HashJoin$$x$8(HashJoin.scala:66) > at > org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.org$apache$spark$sql$execution$joins$HashJoin$$x$8$lzycompute(BroadcastHashJoinExec.scala:38) > at > org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.org$apache$spark$sql$execution$joins$HashJoin$$x$8(BroadcastHashJoinExec.scala:38) > at > org.apache.spark.sql.execution.joins.HashJoin$class.buildKeys(HashJoin.scala:63) > at > org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.buildKeys$lzycompute(BroadcastHashJoinExec.scala:38) > at > org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.buildKeys(BroadcastHashJoinExec.scala:38) > at > org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.requiredChildDistribution(BroadcastHashJoinExec.scala:52) > {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org