(spark) branch master updated: [SPARK-52973][TESTS] Fix the execution failure of StateStoreBasicOperationsBenchmark

[yao]

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

yao 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 f523fdb451c3 [SPARK-52973][TESTS] Fix the execution failure of 
StateStoreBasicOperationsBenchmark
f523fdb451c3 is described below

commit f523fdb451c3ab70a43b5e1ce67ef6341177076b
Author: Kent Yao <y...@apache.org>
AuthorDate: Mon Jul 28 17:47:06 2025 +0800

    [SPARK-52973][TESTS] Fix the execution failure of 
StateStoreBasicOperationsBenchmark
    
    ### What changes were proposed in this pull request?
    A similar PR like #51304 to fix 
https://github.com/yaooqinn/spark/actions/runs/16559193495/job/46827316225
    
    ### Why are the changes needed?
    testfix
    
    ### Does this PR introduce _any_ user-facing change?
    no
    
    ### How was this patch tested?
    Run StateStoreBasicOperationsBenchmark locally
    
    ### Was this patch authored or co-authored using generative AI tooling?
    no
    
    Closes #51683 from yaooqinn/SPARK-52597.
    
    Authored-by: Kent Yao <y...@apache.org>
    Signed-off-by: Kent Yao <y...@apache.org>
---
 .../sql/execution/benchmark/StateStoreBasicOperationsBenchmark.scala  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/StateStoreBasicOperationsBenchmark.scala
 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/StateStoreBasicOperationsBenchmark.scala
index 7c59b06d4b49..18d3b1f5da27 100644
--- 
a/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/StateStoreBasicOperationsBenchmark.scala
+++ 
b/sql/core/src/test/scala/org/apache/spark/sql/execution/benchmark/StateStoreBasicOperationsBenchmark.scala
@@ -465,9 +465,11 @@ object StateStoreBasicOperationsBenchmark extends 
SqlBasedBenchmark {
     val storeId = StateStoreId(newDir(), Random.nextInt(), 0)
     val provider = new HDFSBackedStateStoreProvider()
     val storeConf = new StateStoreConf(new SQLConf())
+    val configuration = new Configuration
+    configuration.set(StreamExecution.RUN_ID_KEY, UUID.randomUUID().toString)
     provider.init(
       storeId, keySchema, valueSchema, NoPrefixKeyStateEncoderSpec(keySchema),
-      useColumnFamilies = false, storeConf, new Configuration)
+      useColumnFamilies = false, storeConf, configuration)
     provider
   }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org