This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
The following commit(s) were added to refs/heads/master by this push:
new ce56aef02 Update logging behavior
ce56aef02 is described below
commit ce56aef0251345495d351ab60f1a9d653fb0d5a7
Author: Gianluca Graziadei <[email protected]>
AuthorDate: Sat Aug 22 12:39:51 2026 +0200
Update logging behavior
---
storm-client/src/jvm/org/apache/storm/StormSubmitter.java | 2 +-
.../src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java | 3 +--
.../jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java | 3 +--
.../jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java | 3 +--
4 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
b/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
index 849fa1a09..18ff3ba60 100644
--- a/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
+++ b/storm-client/src/jvm/org/apache/storm/StormSubmitter.java
@@ -82,7 +82,7 @@ public class StormSubmitter {
|| conf.get(Config.STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD) ==
null
|| !validateZKDigestPayload((String)
conf.get(Config.STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD))) {
secretPayload = generateZookeeperDigestSecretPayload();
- LOG.info("Generated ZooKeeper secret payload for MD5-digest: " +
secretPayload);
+ LOG.info("Generated ZooKeeper secret payload for MD5-digest.");
}
toRet.put(Config.STORM_ZOOKEEPER_TOPOLOGY_AUTH_PAYLOAD, secretPayload);
// This should always be set to digest.
diff --git
a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java
b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java
index 45967b945..ae6372118 100644
--- a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java
+++ b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java
@@ -125,8 +125,7 @@ class SaslNettyServer {
if (pc != null) {
char[] password = SaslUtils.encodePassword(userPassword);
- LOG.debug("handle: SASL server DIGEST-MD5 callback: setting
password for client: ",
- userPassword);
+ LOG.debug("handle: SASL server DIGEST-MD5 callback: setting
password for client");
pc.setPassword(password);
}
diff --git
a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java
b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java
index f1191a222..ca1e57602 100644
---
a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java
+++
b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java
@@ -154,7 +154,6 @@ public class SaslStormClientHandler extends
ChannelInboundHandlerAdapter {
if (secretKey != null) {
token = secretKey.getBytes();
}
- LOG.debug("SASL credentials for storm topology " + name
- + " is " + secretKey);
+ LOG.debug("Obtained SASL credentials for storm topology {}", name);
}
}
diff --git
a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java
b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java
index 181667b2e..d4e127359 100644
---
a/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java
+++
b/storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java
@@ -138,7 +138,6 @@ public class SaslStormServerHandler extends
ChannelInboundHandlerAdapter {
token = secretKey.getBytes();
}
- LOG.debug("SASL credentials for storm topology {} is {}",
- topologyName, secretKey);
+ LOG.debug("Obtained SASL credentials for storm topology {}",
topologyName);
}
}
