Codec fix
Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/d4847797 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/d4847797 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/d4847797 Branch: refs/heads/master Commit: d4847797f6ad1d4bd18ab1b79ceccd36c906f1e7 Parents: e6465b5 Author: Kyle Nusbaum <[email protected]> Authored: Mon Jul 17 14:59:45 2017 -0500 Committer: Kyle Nusbaum <[email protected]> Committed: Mon Jul 17 14:59:45 2017 -0500 ---------------------------------------------------------------------- .../org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/d4847797/storm-server/src/main/java/org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java ---------------------------------------------------------------------- diff --git a/storm-server/src/main/java/org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java b/storm-server/src/main/java/org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java index 0dc6338..80e9c10 100644 --- a/storm-server/src/main/java/org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java +++ b/storm-server/src/main/java/org/apache/storm/pacemaker/codec/ThriftNettyServerCodec.java @@ -47,6 +47,7 @@ public class ThriftNettyServerCodec { private IServer server; private AuthMethod authMethod; private Map<String, Object> topoConf; + private int thriftMessageMaxSize; private static final Logger LOG = LoggerFactory .getLogger(ThriftNettyServerCodec.class); @@ -55,6 +56,7 @@ public class ThriftNettyServerCodec { this.server = server; this.authMethod = authMethod; this.topoConf = topoConf; + this.thriftMessageMaxSize = thriftMessageMaxSize; } public ChannelPipelineFactory pipelineFactory() {
