This is an automated email from the ASF dual-hosted git repository. brahma pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/ambari.git
The following commit(s) were added to refs/heads/trunk by this push: new 1ceb8cbf20 AMBARI-25884: Set Keytab, Check keytab and Remove Keytab operations failing on few clusters (#3657) 1ceb8cbf20 is described below commit 1ceb8cbf20d20002f07f59faad96418a54e7dd51 Author: Murali Krishna <muralikrishna.dm...@gmail.com> AuthorDate: Mon Mar 27 21:59:34 2023 +0530 AMBARI-25884: Set Keytab, Check keytab and Remove Keytab operations failing on few clusters (#3657) Signed-off-by: Brahma Reddy Battula <bra...@apache.org> --- .../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