This is an automated email from the ASF dual-hosted git repository.

yangjie01 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new 58701d811d95 [SPARK-47148][SQL][FOLLOWUP] Use broadcast hint to make 
test more stable
58701d811d95 is described below

commit 58701d811d95918ac4a73d8fb260c46ccbf25bdd
Author: Wenchen Fan <[email protected]>
AuthorDate: Tue Jun 18 16:10:19 2024 +0800

    [SPARK-47148][SQL][FOLLOWUP] Use broadcast hint to make test more stable
    
    ### What changes were proposed in this pull request?
    
    A followup of https://github.com/apache/spark/pull/45234 to make the test 
more stable by using broadcast hint.
    
    ### Why are the changes needed?
    
    test improvement
    
    ### Does this PR introduce _any_ user-facing change?
    
    no
    
    ### How was this patch tested?
    
    N/A
    
    ### Was this patch authored or co-authored using generative AI tooling?
    
    no
    
    Closes #47007 from cloud-fan/follow.
    
    Authored-by: Wenchen Fan <[email protected]>
    Signed-off-by: yangjie01 <[email protected]>
---
 .../apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala
 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala
index 4e1e171c8a84..d6fd45269ce6 100644
--- 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala
+++ 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/adaptive/AdaptiveQueryExecSuite.scala
@@ -961,7 +961,7 @@ class AdaptiveQueryExecSuite
       spark.range(10).toDF("col1").createTempView("t1")
       spark.range(5).coalesce(2).toDF("col2").createTempView("t2")
       spark.range(15).toDF("col3").filter(Symbol("col3") >= 
2).createTempView("t3")
-      sql("SELECT * FROM (SELECT /*+ BROADCAST(t2) */ * FROM t1 " +
+      sql("SELECT /*+ BROADCAST(t3) */ * FROM (SELECT /*+ BROADCAST(t2) */ * 
FROM t1 " +
         "INNER JOIN t2 ON t1.col1 = t2.col2) t JOIN t3 ON t.col1 = t3.col3;")
     }
     withTempView("t1", "t2", "t3") {


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

Reply via email to