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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
