在线&离线storm应用 相关问题解答

book 发布于 2014/08/27 17:12
阅读 733
收藏 0

    本人提供长期免费storm相关问题解答服务,不能解决全部,但希望能够帮助到大家,同时也希望各界storm大神能够多分享分享你们的经验教训~~

    

    交流方式:

    1.本帖下方直接留言

    2.邮箱:search.jerry@gmail.com

    3.QQ:564508735

    4.微信:JERRY910556

加载中
0
0
窗外有个蓝蓝天
窗外有个蓝蓝天
TopologyBuilder builder = new TopologyBuilder();
        
        builder.setSpout("1t", new TestWordSpout(true), 5);
        builder.setSpout("2", new TestWordSpout(true), 3);
        
        builder.setBolt("3", new TestWordCounter(), 3)
            .fieldsGrouping("1", new Fields("word"))
            .fieldsGrouping("2", new Fields("word"));
        
        builder.setBolt("4", new TestGlobalCount())
            .globalGrouping("1");
        
        LocalCluster cluster = new LocalCluster();
        Map<Object, Object> confMap = new HashMap<Object, Object>();
        confMap.put(Config.TOPOLOGY_WORKERS, 4);
        confMap.put(Config.NIMBUS_HOST, "master");
        List<String> zkList = new ArrayList<String>();
        zkList.add("master");
        zkList.add("slave");
        confMap.put(Config.TRANSACTIONAL_ZOOKEEPER_SERVERS, zkList);
        cluster.submitTopology("testtopology", confMap, builder.createTopology());
        Utils.sleep(10000);
        cluster.shutdown();

我写了一个简单的测试程序,但是执行的时候,提示zookeeper连接超时,我估计是哪个配置的参数没有设置,不知道还需要配置哪些参数



窗外有个蓝蓝天
窗外有个蓝蓝天
Storm本地模式下,就不用撘集群的。。。 我理解错了
book
book
1、nc 确认下zookeeper是否可以连接 2、检查下zookeeper连接数是否已经满了,如果是,把zookeeper的limit连接数设置的高点
返回顶部
顶部