You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by xi...@apache.org on 2017/07/20 14:10:04 UTC
[2/5] storm git commit: Codec fix
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 <kn...@yahoo-inc.com>
Authored: Mon Jul 17 14:59:45 2017 -0500
Committer: Kyle Nusbaum <kn...@yahoo-inc.com>
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() {