This is an automated email from the ASF dual-hosted git repository.
jialiang 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 811a7bd5da AMBARI-25892:NamedTasksSubscriptions and
NamedTasksSubscribeListener print logs frequently (#3661)
811a7bd5da is described below
commit 811a7bd5da380365fa026b1744917eef628e70d4
Author: lupeng <[email protected]>
AuthorDate: Mon Jul 29 09:52:52 2024 +0800
AMBARI-25892:NamedTasksSubscriptions and NamedTasksSubscribeListener print
logs frequently (#3661)
---
.../ambari/server/api/stomp/NamedTasksSubscribeListener.java | 6 +++---
.../apache/ambari/server/api/stomp/NamedTasksSubscriptions.java | 8 ++++----
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git
a/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscribeListener.java
b/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscribeListener.java
index 6882236435..f809b42a02 100644
---
a/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscribeListener.java
+++
b/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscribeListener.java
@@ -44,7 +44,7 @@ public class NamedTasksSubscribeListener {
if (sessionId != null && destination != null && id != null) {
namedTasksSubscriptions.addDestination(sessionId, destination, id);
}
- LOG.info(String.format("API subscribe was arrived with sessionId = %s,
destination = %s and id = %s",
+ LOG.debug(String.format("API subscribe was arrived with sessionId = %s,
destination = %s and id = %s",
sessionId, destination, id));
}
@@ -57,7 +57,7 @@ public class NamedTasksSubscribeListener {
if (sessionId != null && id != null) {
namedTasksSubscriptions.removeId(sessionId, id);
}
- LOG.info(String.format("API unsubscribe was arrived with sessionId = %s
and id = %s",
+ LOG.debug(String.format("API unsubscribe was arrived with sessionId = %s
and id = %s",
sessionId, id));
}
@@ -69,7 +69,7 @@ public class NamedTasksSubscribeListener {
if (sessionId != null) {
namedTasksSubscriptions.removeSession(sessionId);
}
- LOG.info(String.format("API disconnect was arrived with sessionId = %s",
+ LOG.debug(String.format("API disconnect was arrived with sessionId = %s",
sessionId));
}
}
diff --git
a/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscriptions.java
b/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscriptions.java
index 09acdf3493..d9cc4c8806 100644
---
a/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscriptions.java
+++
b/ambari-server/src/main/java/org/apache/ambari/server/api/stomp/NamedTasksSubscriptions.java
@@ -69,7 +69,7 @@ public class NamedTasksSubscriptions {
}
return ids;
});
- LOG.info(String.format("Task subscription was added for sessionId = %s,
taskId = %s, id = %s",
+ LOG.debug(String.format("Task subscription was added for sessionId = %s,
taskId = %s, id = %s",
sessionId, taskId, id));
} finally {
taskIdsLock.unlock();
@@ -82,7 +82,7 @@ public class NamedTasksSubscriptions {
while (iterator.hasNext()) {
if (iterator.next().getId().equals(id)) {
iterator.remove();
- LOG.info(String.format("Task subscription was removed for sessionId
= %s, id = %s", sessionId, id));
+ LOG.debug(String.format("Task subscription was removed for sessionId
= %s, id = %s", sessionId, id));
}
}
return tasks;
@@ -98,7 +98,7 @@ public class NamedTasksSubscriptions {
while (iterator.hasNext()) {
if (iterator.next().getTaskId().equals(taskId)) {
iterator.remove();
- LOG.info(String.format("Task subscription was removed for
sessionId = %s and taskId = %s",
+ LOG.debug(String.format("Task subscription was removed for
sessionId = %s and taskId = %s",
sessionId, taskId));
}
}
@@ -114,7 +114,7 @@ public class NamedTasksSubscriptions {
try {
taskIdsLock.lock();
taskIds.remove(sessionId);
- LOG.info(String.format("Task subscriptions were removed for sessionId =
%s", sessionId));
+ LOG.debug(String.format("Task subscriptions were removed for sessionId =
%s", sessionId));
} finally {
taskIdsLock.unlock();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
