This is an automated email from the ASF dual-hosted git repository.
zhztheplayer pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/gluten.git
The following commit(s) were added to refs/heads/main by this push:
new 11d1e8766b [VL][CH] Preserve broadcast resource IDs during concurrent
registration (#13320)
11d1e8766b is described below
commit 11d1e8766bf4905a956d44470d74bafd056fa8c9
Author: Kaifei Yi <[email protected]>
AuthorDate: Fri Oct 16 18:59:44 2026 +0800
[VL][CH] Preserve broadcast resource IDs during concurrent registration
(#13320)
---
.../src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala | 2 +-
.../src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/backends-clickhouse/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
b/backends-clickhouse/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
index 4965cf1bd3..bb337573f1 100644
---
a/backends-clickhouse/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
+++
b/backends-clickhouse/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
@@ -119,7 +119,7 @@ object GlutenDriverEndpoint extends Logging
def collectResources(executionId: String, resourceId: String): Unit = {
val resources = executionResourceRelation
- .get(executionId, (_: String) => new util.HashSet[String]())
+ .get(executionId, (_: String) =>
java.util.concurrent.ConcurrentHashMap.newKeySet[String]())
resources.add(resourceId)
}
diff --git
a/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
b/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
index e8b96b9697..73d81d6823 100644
---
a/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
+++
b/backends-velox/src/main/scala/org/apache/spark/rpc/GlutenDriverEndpoint.scala
@@ -117,7 +117,7 @@ object GlutenDriverEndpoint extends Logging
def collectResources(executionId: String, resourceId: String): Unit = {
val resources = executionResourceRelation
- .get(executionId, (_: String) => new util.HashSet[String]())
+ .get(executionId, (_: String) =>
java.util.concurrent.ConcurrentHashMap.newKeySet[String]())
resources.add(resourceId)
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
