You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@spark.apache.org by "zuotingbing (Jira)" <ji...@apache.org> on 2024/09/05 07:41:00 UTC
[jira] [Commented] (SPARK-49522) when udf added with '+' for many times , the drvier process hangs at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType
[ https://issues.apache.org/jira/browse/SPARK-49522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17879470#comment-17879470 ]
zuotingbing commented on SPARK-49522:
-------------------------------------
[https://github.com/apache/spark/pull/42804] resolved
> when udf added with '+' for many times , the drvier process hangs at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType
> ----------------------------------------------------------------------------------------------------------------------------------------
>
> Key: SPARK-49522
> URL: https://issues.apache.org/jira/browse/SPARK-49522
> Project: Spark
> Issue Type: Bug
> Components: SQL
> Affects Versions: 3.4.1
> Reporter: zuotingbing
> Priority: Major
>
> spark-sql --master local[4] --total-executor-cores 1 --executor-cores 3 --executor-memory 4g
> spark-sql (default)>create table ztbtest(age int);
> spark-sql (default)>insert into ztbtest values(1);
> spark-sql (default)>select sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age)+sum(age) from ztbtest;
>
>
> jstack.log
> "Thread-6" #17 prio=5 os_prio=0 tid=0x00007f1788012000 nid=0x13f93c runnable [0x00007f17a03f8000]
> java.lang.Thread.State: RUNNABLE
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:236)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> at org.apache.spark.sql.catalyst.expressions.BinaryArithmetic.dataType(arithmetic.scala:239)
> ......
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscribe@spark.apache.org
For additional commands, e-mail: issues-help@spark.apache.org