Bit of cleanup
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2fa4d255 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2fa4d255 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2fa4d255 Branch: refs/heads/master Commit: 2fa4d255bc44cbf31bae577551bfe406626a68ef Parents: 9c2ac7d Author: Kyle Nusbaum <[email protected]> Authored: Wed May 4 11:00:51 2016 -0500 Committer: Kyle Nusbaum <[email protected]> Committed: Wed May 4 11:00:51 2016 -0500 ---------------------------------------------------------------------- .../src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2fa4d255/storm-core/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java ---------------------------------------------------------------------- diff --git a/storm-core/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java b/storm-core/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java index 7f21cf8..ce9c899 100644 --- a/storm-core/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java +++ b/storm-core/src/jvm/org/apache/storm/pacemaker/codec/ThriftDecoder.java @@ -50,12 +50,10 @@ public class ThriftDecoder extends FrameDecoder { return null; } - byte serialized[] = new byte[thriftLen]; buf.readBytes(serialized, 0, thriftLen); HBMessage m = (HBMessage)Utils.thriftDeserialize(HBMessage.class, serialized); - if(m.get_type() == HBServerMessageType.CONTROL_MESSAGE) { ControlMessage cm = ControlMessage.read(m.get_data().get_message_blob()); return cm;
