longvu-db commented on PR #55463:
URL: https://github.com/apache/spark/pull/55463#issuecomment-4568494522

   > [info] LogicalPlanTagInSparkPlanSuite:
   [info] - q1 (282 milliseconds)
   [info] - q2 *** FAILED *** (169 milliseconds)
   [info]   java.lang.IllegalArgumentException: requirement failed: 
UnionExec.doConsume invoked outside doProduce emission window
   [info]   at scala.Predef$.require(Predef.scala:337)
   [info]   at 
org.apache.spark.sql.execution.UnionExec.doConsume(basicPhysicalOperators.scala:1066)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.consume(WholeStageCodegenExec.scala:207)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.consume$(WholeStageCodegenExec.scala:160)
   [info]   at 
org.apache.spark.sql.execution.ProjectExec.consume(basicPhysicalOperators.scala:44)
   [info]   at 
org.apache.spark.sql.execution.ProjectExec.doConsume(basicPhysicalOperators.scala:92)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.consume(WholeStageCodegenExec.scala:207)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.consume$(WholeStageCodegenExec.scala:160)
   [info]   at 
org.apache.spark.sql.execution.ColumnarToRowExec.consume(Columnar.scala:67)
   [info]   at 
org.apache.spark.sql.execution.ColumnarToRowExec.doProduce(Columnar.scala:190)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:269)
   [info]   at 
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:169)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:266)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.ColumnarToRowExec.produce(Columnar.scala:67)
   [info]   at 
org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:58)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:269)
   [info]   at 
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:169)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:266)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.ProjectExec.produce(basicPhysicalOperators.scala:44)
   [info]   at 
org.apache.spark.sql.execution.UnionExec.$anonfun$doProduce$4(basicPhysicalOperators.scala:1036)
   [info]   at scala.collection.immutable.Vector1.map(Vector.scala:2141)
   [info]   at scala.collection.immutable.Vector1.map(Vector.scala:386)
   [info]   at 
org.apache.spark.sql.execution.UnionExec.doProduce(basicPhysicalOperators.scala:1034)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:269)
   [info]   at 
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:169)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:266)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.UnionExec.produce(basicPhysicalOperators.scala:826)
   [info]   at 
org.apache.spark.sql.execution.joins.HashJoin.doProduce(HashJoin.scala:361)
   [info]   at 
org.apache.spark.sql.execution.joins.HashJoin.doProduce$(HashJoin.scala:360)
   [info]   at 
org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.doProduce(BroadcastHashJoinExec.scala:40)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.$anonfun$produce$1(WholeStageCodegenExec.scala:99)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.$anonfun$executeQuery$1(SparkPlan.scala:269)
   [info]   at 
org.apache.spark.rdd.RDDOperationScope$.withScope(RDDOperationScope.scala:169)
   [info]   at 
org.apache.spark.sql.execution.SparkPlan.executeQuery(SparkPlan.scala:266)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.CodegenSupport.produce$(WholeStageCodegenExec.scala:94)
   [info]   at 
org.apache.spark.sql.execution.joins.BroadcastHashJoinExec.produce(BroadcastHashJoinExec.scala:40)
   [info]   at 
org.apache.spark.sql.execution.ProjectExec.doProduce(basicPhysicalOperators.scala:58)
   
   Unrelated test failure


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to