You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@gluten.apache.org by ho...@apache.org on 2026/10/16 10:59:50 UTC
(gluten) branch main updated: [VL][CH] Preserve broadcast resource IDs during concurrent registration (#13320)
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 <yi...@apache.org>
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: commits-unsubscribe@gluten.apache.org
For additional commands, e-mail: commits-help@gluten.apache.org