fix

s0nskar · s0nskar · commit d1587e3fded3 · 2026-06-26T19:57:43.000+05:30
diff --git a/master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala b/master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala
@@ -72,7 +72,7 @@ class TagsManager(configService: Option[ConfigService]) extends Logging {
     val storeTags = tagStore.map(_.asScala.collect {
       case (tag, workerIds) if workerIds.contains(worker.toUniqueId) => tag
     }.toSet).getOrElse(Set.empty)
-    storeTags ++ worker.tags
+    storeTags ++ worker.tags.asScala
   }
 
   def getTagsForCluster: Set[String] = {

Original file line number	Diff line number	Diff line change
`@@ -72,7 +72,7 @@ class TagsManager(configService: Option[ConfigService]) extends Logging {`
`72`	`72`	`val storeTags = tagStore.map(_.asScala.collect {`
`73`	`73`	`case (tag, workerIds) if workerIds.contains(worker.toUniqueId) => tag`
`74`	`74`	`}.toSet).getOrElse(Set.empty)`
`75`		`- storeTags ++ worker.tags`
	`75`	`+ storeTags ++ worker.tags.asScala`
`76`	`76`	`}`
`77`	`77`
`78`	`78`	`def getTagsForCluster: Set[String] = {`