apache storm 1.1.0未运行，无法从客户端sessionid读取其他数据

我正在ApacheStorm1.1.0中运行一个简单的hello world类应用程序。应用程序有一个随机整数喷口和一个打印元组输出的螺栓。但不知怎么的，我无法让它在我的windows系统上工作。
我是新来的Apache风暴和以下教程。我已经在stack overflow中找到了答案，但是没有找到任何关于这个问题的答案。
以下是我的运行拓扑代码：

public static void runTopology() {
    //String filePath = "./src/main/resources/operations.txt";
    TopologyBuilder builder = new TopologyBuilder();
    builder.setSpout("randomNumberSpout", new RandomIntSpout());
    builder.setBolt("printingBolt", new PrintingBolt()).shuffleGrouping("randomNumberSpout");

    Config config = new Config();
    config.setDebug(true);
    LocalCluster cluster = new LocalCluster();
    try{
        cluster.submitTopology("Test", config, builder.createTopology());
    }finally{
        cluster.shutdown();
    }
}

螺栓代号

public class PrintingBolt extends BaseBasicBolt {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    public void execute(Tuple tuple, BasicOutputCollector basicOutputCollector) {
        System.out.println("Printing Tupple!!!!");
        System.out.println(tuple);
        System.out.println("Tupple processed " + tuple.getInteger(1));
        basicOutputCollector.emit(new Values(tuple.getInteger(1)));
    }

    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declare(new Fields("TestOutput"));

    }
}

喷口代码

public class RandomIntSpout extends BaseRichSpout {

    /**
     * 
     */
    private static final long serialVersionUID = 1L;

    private Random random;
    private SpoutOutputCollector outputCollector;

    /*@Override
    public void open(Map<String,Object> map, TopologyContext topologyContext,
      SpoutOutputCollector spoutOutputCollector) {
        random = new Random();
        outputCollector = spoutOutputCollector;
    }*/

    public void nextTuple() {
        Utils.sleep(1000);
        outputCollector.emit(new Values(random.nextInt(), System.currentTimeMillis()));
    }

    public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
        outputFieldsDeclarer.declare(new Fields("randomInt", "timestamp"));
    }

    public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
            random = new Random();
            outputCollector = collector;
    }
}

我也可以提供其余的代码，但我不认为这是必需的。如果需要，请在评论中提及，我也会提供。
每当我尝试运行应用程序时，都会出现以下错误。
10620[main]info o.a.s.s.o.a.z.zookeeper-启动客户端连接，连接字符串=localhost:2000/storm sessiontimeout=20000>watcher=org.apache.storm.shade.org.apache.curator。connectionstate@31b0f02 10625[主发送线程（0:0:0:0:0:0:0:1:2000）]信息o.a.s.o.a.z.clientcnxn-打开到服务器的套接字连接>0:0:0:0:0:0:1/0:0:0:0:0:0:0:1:2000。不会尝试使用sasl（未知错误）10627[主发送线程（0:0:0:0:0:0:0:1:2000）]info o.a.s.s.o.a.z.clientcnxn-已建立到>0:0:0:0:0:0:1/0:0:0:0:0:0:1:2000的套接字连接进行身份验证，启动会话10627[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]信息o.a.s.s.o.a.z.s.nioservercnxnfactory-接受来自/>0:0:0:0:0:0:1:56905 10628的套接字连接[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]信息o.a.s.s.o.a.z.s.zookeeperserver-客户端尝试在/>0:0:0:0:0:0:1:56905 10631建立新会话[主发送线程（0:0:0:0:0:0:0:0:1:2000）]信息o.a.s.s.o.a.z.clientcnxn-在服务器上完成会话建立>0:0:0:0:0:0:1/0:0:0:0:0:1:2000，sessionid=0x16a8e5abd97000d，协商超时=20000 10631[syncthread:0]info o.a.s.s.o.a.z.s.zookeeperserver-已为客户端建立会话0x16a8e5abd97000d，协商超时20000/>0:0:0:0:0:0:1:56905
10632[main eventthread]info o.a.s.s.o.a.c.f.s.connectionstatemanager-状态更改：connected 10635[processthread](sid:0 cport：-1）：]info o.a.s.s.o.a.z.s.prerequestprocessor-处理时获得用户级keeperexceptionsessionid:0x16a8e5abd97000d type：创建cxid:0x2 zxid：0x26txntype:-1 reqpath：不适用错误路径：/storm/blobstoremaxkeysequencenumber>error:keepererrorcode = /storm/blobstoremaxkeysequencenumber 10655[curator-framework-0]info o.a.s.s.o.a.c.f.i.curatorframeworkimpl-backgroundoperationsloop退出10657[processthread]的非代码(sid:0 cport：-1）：]info o.a.s.s.o.a.z.s.prerequestprocessor-已处理的会话终止sessionid:>0x16a8e5abd97000d 10659[main eventthread]info o.a.s.o.a.z.clientcnxn-eventthread shut down 10659[main]info o.a.s.o.a.z.zookeeper-session:0x16a8e5abd97000d closed 10661[main]info o.a.s.cluster-setup path/blobstore/test-1-1557166474-stormconf.ser/ibmt450pc053rlv.corp.cvs。com:6627-1 10660 [nioservercxn。factory:0.0.0.0/0.0.0.0：2000]warn o.a.s.s.o.a.z.s.nioservercnxn-捕获到流结束异常org.apache.storm.shade.org.apache.zookeeper.server.servercnxn$endofstreamexception:无法从客户端sessionid>0x16a8e5abd97000d读取其他数据，可能客户端已经关闭了org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxn.doio（nioservercnxn）上的套接字。java:228)[风暴核心-1.1.0。jar:1.1.0]访问org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxnfactory.run（nioservercnxnfactory）。java:208)[风暴核心-1.1.0。jar:1.1.0]在java.lang.thread.run（线程。java:745) [？：1.8.060]10671[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]info o.a.s.o.a.z.s.nioservercnxn-客户端的关闭套接字连接/>0:0:0:0:0:0:1:56905，其sessionid 0x16a8e5abd97000d 10746[main]info o.a.s.o.a.c.f.i.curatorframeworkimpl-启动10747[main]info o.a.s.s.o.a.z.zookeeper-启动客户端连接，连接字符串=localhost:2000/storm sessiontimeout=20000>watcher=org.apache.storm.shade.org.apache.curator。connectionstate@73893ec1 10755[main sendthread（127.0.0.1:2000）]info o.a.s.s.o.a.z.clientcnxn-打开到服务器127.0.0.1/127.0.0.1:2000的套接字连接。将不>尝试使用sasl（未知错误）10756[主发送线程（127.0.0.1:2000）]info o.a.s.s.o.a.z.clientcnxn进行身份验证-已建立到127.0.0.1/127.0.0.1:2000的套接字连接，初始化>会话10758[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]信息o.a.s.s.o.a.z.s.nioservercnxnfactory-接受来自/127.0.0.1:56908 10759的套接字连接[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]信息o.a.s.s.o.a.z.s.zookeeperserver-客户端正在尝试建立新会话，电话>/127.0.0.1:56908 10766[主发送线程（127.0.0.1:2000）]信息o.a.s.s.o.a.z.clientcnxn-在服务器127.0.0.1/127.0.0.1:2000上完成会话建立，>sessionid=0x16a8e5abd97000e，协商超时=20000 10766[syncthread:0]info o.a.s.s.o.a.z.s.zookeeperserver-已为客户端建立会话0x16a8e5abd97000e，协商超时20000>/127.0.0.1:56908 10767[main eventthread]info o.a.s.s.o.a.c.f.s.connectionstatemanager-状态更改：connected 10778[curator-framework-0]infoo、 a.s.s.o.a.c.f.i.curatorframeworkimpl-后台操作循环退出10781[processthread](sid:0 cport：-1）：]info o.a.s.s.o.a.z.s.prerequestProcessor-已处理sessionid的会话终止：>0x16a8e5abd97000e 10785[main]info o.a.s.s.o.a.z.zookeeper-会话：0x16a8e5abd97000e closed 10785[nioservercxn。factory:0.0.0.0/0.0.0.0:2000] info o.a.s.s.o.a.z.s.nioservercnxn-客户端的封闭套接字连接/127.0.0.1:56908>会话ID为0x16a8e5abd97000e 10785[main]info o.a.s.cluster-安装路径/blobstore/test-1-1557166474-stormcode.ser/ibmt450pc053rlv.corp.cvs。com:6627-1 10786 [main eventthread]info o.a.s.s.o.a.z.clientcnxn-事件线程关闭10821[main]信息o、 a.s.d.nimbus—达到所需的复制计数1，conf key=1的当前复制计数，code key=1的当前复制计数>，jar key的当前复制计数=1 11042[main]info o.a.s.d.nimbus-激活测试：test-1-1557166474 11058[main]info o.a.s.d.nimbus-关闭主机11064[curator-framework-0]info o.a.s.o.a.c.f.i.curatorframeworkimpl-backgroundoperationsloop退出11066[processthread](sid:0 cport：-1）：]信息o、 a.s.s.o.a.z.s.prerequestProcessor-已处理sessionid的会话终止：>0x16a8e5abd970003 11068[main eventthread]info o.a.s.o.a.z.clientcnxn-事件线程关闭11069[nioservercxn]。factory:0.0.0.0/0.0.0.0：2000]warn o.a.s.s.o.a.z.s.nioservercnxn-捕获到流结束异常org.apache.storm.shade.org.apache.zookeeper.server.servercnxn$endofstreamexception:无法从客户端sessionid>0x16a8e5abd970003读取其他数据，可能客户端已经关闭了org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxn.doio（nioservercnxn）上的套接字。java:228)[风暴核心-1.1.0。jar:1.1.0]访问org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxnfactory.run（nioservercnxnfactory）。java:208)[风暴核心-1.1.0。jar:1.1.0]在java.lang.thread.run（线程。java:745) [？：1.8.0\u 60]11068[main]info o.a.s.s.o.a.z.zookeeper-会话：0x16a8e5abd970003关闭11069[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]info o.a.s.s.o.a.z.s.nioservercnxn-客户端的封闭套接字连接/127.0.0.1:56875>会话ID为0x16a8e5abd970003 11069[curator-framework-0]info o.a.s.o.a.c.f.i.curatorframeworkimpl-backgroundoperationsloop退出11072[processthread](sid:0 cport：-1）：]info o.a.s.s.o.a.z.s.prerequestprocessor-已处理sessionid的会话终止：>0x16a8e5abd97000411074[main eventthread]info o.a.s.s.o.a.z.clientcnxn-eventthread shutdown 11075[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]信息o.a.s.s.o.a.z.s.nioservercnxn-客户端的闭合套接字连接/>0:0:0:0:0:0:1:56878，其sessionid为0x16a8e5abd97000411074[main]info o.a.s.o.a.z.zookeeper-session:0x16a8e5abd970004 closed 11077[curator-framework-0]info o.a.s.o.a.c.f.i.curatorframeworkimpl-backgroundoperationsloop退出11079[processthread](sid:0 cport：-1）：]信息o、 a.s.o.a.z.s.PrerequestProcessor-已处理会话终止sessionid:>0x16a8e5abd970000 11081[main]信息o.a.s.o.a.z.zookeeper-会话：0x16a8e5abd970000关闭11081[main]信息o.a.s.zookeeper-关闭leader elector的zookeeper连接。11082[main eventthread]info o.a.s.s.o.a.z.clientcnxn-eventthread shut down 11082[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]info o.a.s.s.o.a.z.s.nioservercnxn-客户端的封闭套接字连接/127.0.0.1:56866>会话ID为0x16a8e5abd970000 11082[curator-framework-0]info o.a.s.o.a.c.f.i.curatorframeworkimpl-backgroundoperationsloop退出11084[processthread](sid:0 cport：-1）：]info o.a.s.s.o.a.z.s.prerequestProcessor-已处理sessionid的会话终止：>0x16a8e5abd970001 11086[main]info o.a.s.s.o.a.z.zookeeper-会话：0x16a8e5abd970001关闭11087[main eventthread]info o.a.s.o.a.z.clientcnxn-eventthread关闭11087[main]info o.a.s.d.nimbus-关闭主机11087[curator-framework-0]info o.a.s.s.o.a.c.f.i.curatorframeworkimpl-后台操作循环退出11089[nioservercxn]。factory:0.0.0.0/0.0.0.0：2000]warn o.a.s.s.o.a.z.s.nioservercnxn-捕获到流结束异常org.apache.storm.shade.org.apache.zookeeper.server.servercnxn$endofstreamexception:无法从客户端sessionid>0x16a8e5abd970001读取其他数据，可能客户端已经关闭了org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxn.doio（nioservercnxn）上的套接字。java:228)[风暴核心-1.1.0。jar:1.1.0]访问org.apache.storm.shade.org.apache.zookeeper.server.nioservercnxnfactory.run（nioservercnxnfactory）。java:208)[风暴核心-1.1.0。jar:1.1.0]在java.lang.thread.run（线程。java:745) [？：1.8.060]11089[nioservercxn。factory:0.0.0.0/0.0.0.0：2000]info o.a.s.s.o.a.z.s.nioservercnxn-客户端的封闭套接字连接/127.0.0.1:56869>会话ID为0x16a8e5abd970001 11090[processthread](sid:0 cport：-1）：]信息o.a.s.s.o.a.z.s.PrerequestProcesso

apache storm 1.1.0未运行，无法从客户端sessionid读取其他数据

暂无答案！

相关问题

热门标签

最新问答