Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Remove redundant logging, correct logged class.

  • Loading branch information...
commit 974bf24acd61be8df36a13985b785bf56123761f 1 parent c9f3183
@d2r d2r authored
View
4 src/jvm/backtype/storm/security/serialization/BlowfishTupleSerializer.java
@@ -26,7 +26,7 @@
* You should use in via "storm -c topology.tuple.serializer.blowfish.key=YOURKEY -c topology.tuple.serializer=backtype.storm.security.serialization.BlowfishTupleSerializer jar ...".
*/
public static String SECRET_KEY = "topology.tuple.serializer.blowfish.key";
- private static final Logger LOG = Logger.getLogger(BlowfishSerializer.class);
+ private static final Logger LOG = Logger.getLogger(BlowfishTupleSerializer.class);
private BlowfishSerializer _serializer;
public BlowfishTupleSerializer(Kryo kryo, Map storm_conf) {
@@ -35,13 +35,11 @@ public BlowfishTupleSerializer(Kryo kryo, Map storm_conf) {
encryption_key = (String)storm_conf.get(SECRET_KEY);
LOG.debug("Blowfish serializer being constructed ...");
if (encryption_key == null) {
- LOG.error("Encryption key not specified");
throw new RuntimeException("Blowfish encryption key not specified");
}
byte[] bytes = Hex.decodeHex(encryption_key.toCharArray());
_serializer = new BlowfishSerializer(new ListDelegateSerializer(), bytes);
} catch (org.apache.commons.codec.DecoderException ex) {
- LOG.error("Invalid encryption key", ex);
throw new RuntimeException("Blowfish encryption key invalid", ex);
}
}
Please sign in to comment.
Something went wrong with that request. Please try again.