Github user danny0405 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2842#discussion_r218691752
--- Diff:
storm-client/src/jvm/org/apache/storm/security/auth/workertoken/WorkerTokenAuthorizer.java
---
@@ -112,13 +112,21 @@ private static IStormClusterState
buildStateIfNeeded(Map<String, Object> conf, T
if (keyCache == null) {
return Optional.empty();
}
+ byte[] user = null;
+ WorkerTokenInfo deser = null;
+ try {
+ user = Base64.getDecoder().decode(userName);
+ deser = Utils.deserialize(user, WorkerTokenInfo.class);
+ } catch (Exception e) {
+ LOG.debug("Could not decode {}, might just be a plain digest
request...", userName, e);
+ return Optional.empty();
--- End diff --
Could we change to LOG.INFO if the request it not that frequentï¼we can
see more details from the log.
---