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/c886c8d7 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/c886c8d7 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/c886c8d7 Branch: refs/heads/1.x-branch Commit: c886c8d7190815332556bff9c5494ee2f07c3ea6 Parents: 3280fcf Author: Kyle Nusbaum <[email protected]> Authored: Wed May 4 11:00:51 2016 -0500 Committer: Jungtaek Lim <[email protected]> Committed: Mon May 16 18:18:01 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/c886c8d7/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;
