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/c8d97d13 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c8d97d13 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c8d97d13 Branch: refs/heads/1.0.x-branch Commit: c8d97d133492680e52f70c4b0240ab119c953614 Parents: bef6f70 Author: Kyle Nusbaum <[email protected]> Authored: Wed May 4 11:00:51 2016 -0500 Committer: Jungtaek Lim <[email protected]> Committed: Mon May 16 18:23:48 2016 +0900 ---------------------------------------------------------------------- .../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/c8d97d13/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;
