[ambari] branch branch-2.7 updated: AMBARI-25884: Set Keytab, Check keytab and Remove Keytab operations failing on few clusters (#3691)

[vjasani]

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

vjasani pushed a commit to branch branch-2.7
in repository https://gitbox.apache.org/repos/asf/ambari.git


The following commit(s) were added to refs/heads/branch-2.7 by this push:
     new 88fdda409a AMBARI-25884: Set Keytab, Check keytab and Remove Keytab 
operations failing on few clusters (#3691)
88fdda409a is described below

commit 88fdda409ab2c58b5bb7a06e125cf5a3e3ebfb27
Author: Murali Krishna <muralikrishna.dm...@gmail.com>
AuthorDate: Sat Jun 3 12:11:03 2023 +0530

    AMBARI-25884: Set Keytab, Check keytab and Remove Keytab operations failing 
on few clusters (#3691)
---
 .../ambari/server/events/publishers/AgentCommandsPublisher.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/ambari-server/src/main/java/org/apache/ambari/server/events/publishers/AgentCommandsPublisher.java
 
b/ambari-server/src/main/java/org/apache/ambari/server/events/publishers/AgentCommandsPublisher.java
index 7249ad5646..27f5115079 100644
--- 
a/ambari-server/src/main/java/org/apache/ambari/server/events/publishers/AgentCommandsPublisher.java
+++ 
b/ambari-server/src/main/java/org/apache/ambari/server/events/publishers/AgentCommandsPublisher.java
@@ -35,6 +35,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.TreeMap;
+import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.ExecutionException;
 
 import javax.annotation.Nullable;
@@ -95,8 +96,8 @@ public class AgentCommandsPublisher {
 
   public void sendAgentCommand(Multimap<Long, AgentCommand> agentCommands) 
throws AmbariRuntimeException {
     if (agentCommands != null && !agentCommands.isEmpty()) {
-      Map<Long, TreeMap<String, ExecutionCommandsCluster>> 
executionCommandsClusters = new TreeMap<>();
-      Map<Long, Map<String, DesiredConfig>> clusterDesiredConfigs = new 
HashMap<>();
+      Map<Long, TreeMap<String, ExecutionCommandsCluster>> 
executionCommandsClusters = new ConcurrentHashMap<>();
+      Map<Long, Map<String, DesiredConfig>> clusterDesiredConfigs = new 
ConcurrentHashMap<>();
 
       try {
         threadPools.getAgentPublisherCommandsPool().submit(() -> {


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