Got an IOException in internalRead! java.io.IOException: Connection reset by peer
按照你的方式还是不行, 执行storm jar test.jar storm.starter.simple.SimpleTopology testdrpc时,在监控界面上可以看到emitted数目,但是执行storm jar test.jar storm.starter.BasicDRPCTopology basicdemo时,在监控界面上可以看到emitted始终为0,
评论删除后,数据将无法恢复