使用Thrift API监控Storm集群和Topology获取集群对象报错

Question

org.apache.thrift.transport.TTransportException: Frame size (1213486160) larger than max length (16384000)!
at org.apache.thrift.transport.TFramedTransport.readFrame(TFramedTransport.java:137)
at org.apache.thrift.transport.TFramedTransport.read(TFramedTransport.java:101)
at org.apache.thrift.transport.TTransport.readAll(TTransport.java:86)
at org.apache.thrift.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429)
at org.apache.thrift.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318)
at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219)
at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:69)
at backtype.storm.generated.Nimbus$Client.recv_getClusterInfo(Nimbus.java:465)
at backtype.storm.generated.Nimbus$Client.getClusterInfo(Nimbus.java:453)
at com.damacheng009.storm.monitor.logic.Logic.getTopoExpSize(Logic.java:29)
at com.damacheng009.storm.monitor.Test.get(Test.java:34)
at com.damacheng009.storm.monitor.Test.main(Test.java:84)

ClusterSummary clusterSummary = client.getClient().getClusterInfo(); 


 client = ClientManager.getClient("192.168.225.128", 8899);