DRPC topology about storm UI

[马庆祥]

Hello all,

I have a question about DRPC topology, the topology code is：

public class Test {
    public static void main(String[] args) throws Exception {
        String toponame = "Test"; //set topology name
        Config conf = new Config();
        TopologyBuilder builder = new TopologyBuilder();
        builder.setSpout("Spout", new DRPCSpout(toponame), 1);
        builder.setBolt("MD5", new DrpcSplit(), 1).shuffleGrouping("Spout");
        builder.setBolt("Return", new ReturnResults(),
1).shuffleGrouping("MD5");
        StormSubmitter.submitTopology(toponame, conf, builder.createTopology());
    }
}


the verification mode for the drpc topology is：

1、curl -d "hello” http://drpc_hostname:3774/drpc/Test, the return result is
correct.

2、new DRPCClient(conf, host, 3772); the return result is also correct.

And, the drpc log and worker log is ok.

But, the storm UI is abnormal, the Topology stats all is 0, and the Spout
stats is also 0. Why is this case?
[image: 内嵌图片 2]

[image: 内嵌图片 1]


Thanks & Regards
Qingxiang Ma