【发布时间】：2019-05-06 18:33:20
【问题描述】：
我在 Apache Storm 1.1.0 中运行一个简单的 Hello World 类型的应用程序。应用程序有一个随机整数 spout 和一个打印元组输出的 bolt。但不知何故，我无法让它在我的 Windows 系统上运行。
我是 Apache Storm 的新手，正在学习教程。我已经在堆栈溢出中寻找答案，但我找不到任何已解决的问题。
以下是我运行的拓扑代码：
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;
}
}
我也可以提供其余代码，但我认为这不是必需的。如果需要，请在 cmets 中提及，我也会提供。
每当我尝试运行应用程序时都会收到以下错误。
10620 [main] INFO o.a.s.s.o.a.z.ZooKeeper - 启动客户端连接，connectString=localhost:2000/storm sessionTimeout=20000 > watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@31b0f02 10625 [main-SendThread(0:0:0:0:0:0:0:1:2000)] 信息 o.a.s.s.o.a.z.ClientCnxn - 打开与服务器的套接字连接 > 0:0:0:0:0:0:0:1 /0:0:0:0:0:0:0:1:2000。不会尝试使用 SASL 进行身份验证（未知错误） 10627 [main-SendThread(0:0:0:0:0:0:0:1:2000)] 信息 o.a.s.s.o.a.z.ClientCnxn - 套接字连接建立到 > 0:0:0:0:0:0:0:1/ 0: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: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:0:1:56905 建立新会话 10631 [main-SendThread(0:0:0:0:0:0:0:1:2000)] 信息 o.a.s.s.o.a.z.ClientCnxn - 服务器上的会话建立完成 > 0:0:0:0:0:0:0:1 /0:0: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:0:1:56905
10632 [main-EventThread] 信息 o.a.s.s.o.a.c.f.s.ConnectionStateManager - 状态更改：已连接 10635 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - 处理 sessionid 时出现用户级 KeeperException：0x16a8e5abd97000d 类型：创建 cxid:0x2 zxid:0x26 txntype:-1 reqpath:n/a 错误路径：/ Storm/blobstoremaxkeysequencenumber > 错误：KeeperErrorCode = NoNode for /storm/blobstoremaxkeysequencenumber 10655 [Curator-Framework-0] 信息 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.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd97000d 10659 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 10659 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd97000d 已关闭 10661 [main] 信息 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) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 10671 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端的关闭套接字连接 /> 0:0:0:0:0:0:0:1:56905 其 sessionid 为 0x16a8e5abd97000d 10746 [main] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - 开始 10747 [main] INFO o.a.s.s.o.a.z.ZooKeeper - 启动客户端连接，connectString=localhost:2000/storm sessionTimeout=20000 > watcher=org.apache.storm.shade.org.apache.curator.ConnectionState@73893ec1 10755 [main-SendThread(127.0.0.1:2000)] 信息 o.a.s.s.o.a.z.ClientCnxn - 打开与服务器 127.0.0.1/127.0.0.1:2000 的套接字连接。不会 > 尝试使用 SASL 进行身份验证（未知错误） 10756 [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 建立的套接字连接，正在启动 > 会话 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 [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 上的会话建立完成，> 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] 信息 o.a.s.s.o.a.c.f.s.ConnectionStateManager - 状态更改：已连接 10778 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 10781 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd97000e 10785 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd97000e 已关闭 10785 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端 /127.0.0.1:56908 > 的已关闭套接字连接，其 sessionid 为 0x16a8e5abd97000e 10785 [主要] 信息 o.a.s.cluster - setup-path/blobstore/Test-1-1557166474-stormcode.ser/IBMT450PC053RLV.Corp.CVS.com:6627-1 10786 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 10821 [main] INFO o.a.s.d.nimbus - 达到所需的复制计数 1，conf 密钥的当前复制计数 = 1，当前复制计数 > 代码密钥 = 1，jar 密钥的当前复制计数 = 1 11042 [main] INFO o.a.s.d.nimbus - 激活测试：Test-1-1557166474 11058 [main] INFO o.a.s.d.nimbus - 关闭主机 11064 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11066 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970003 11068 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 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) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11068 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970003 已关闭 11069 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端 /127.0.0.1:56875 > 的已关闭套接字连接，其 sessionid 为 0x16a8e5abd970003 11069 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11072 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970004 11074 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11075 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端的关闭套接字连接 /> 0:0:0:0:0:0:0:1:56878 其 sessionid 为 0x16a8e5abd970004 11074 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970004 已关闭 11077 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11079 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970000 11081 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970000 已关闭 11081 [main] INFO o.a.s.zookeeper - 关闭领导选举人的 zookeeper 连接。 11082 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11082 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端 /127.0.0.1:56866 > 的已关闭套接字连接，其 sessionid 为 0x16a8e5abd970000 11082 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11084 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970001 11086 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970001 已关闭 11087 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11087 [main] INFO o.a.s.d.nimbus - 关闭主机 11087 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 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) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11089 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端 /127.0.0.1:56869 > 的已关闭套接字连接，其 sessionid 为 0x16a8e5abd970001 11090 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970006 11092 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970006 已关闭 11093 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11093 [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 > 0x16a8e5abd970006 读取其他数据，可能客户端已关闭套接字 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11094 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 已关闭客户端 /127.0.0.1:56884 > 的套接字连接，其 sessionid 为 0x16a8e5abd970006 11095 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11095 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd970008 11098 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd970008 已关闭 11098 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1024,5,main] 分配设置为 null 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1025,5,main] 分配设置为 null 11099 [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 > 0x16a8e5abd970008 读取其他数据，可能客户端已关闭套接字 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11099 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1026,5,main] 分配设置为 null 11099 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1024,5,main] 为 EMPTY，当前为 EMPTY 11099 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1025,5,main] 为 EMPTY，当前为 EMPTY 11099 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端的关闭套接字连接 /> 0:0:0:0:0:0:0:1:56890 其 sessionid 为 0x16a8e5abd970008 11099 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1026,5,main] 为 EMPTY，当前为 EMPTY 11099 [main] INFO o.a.s.d.s.Supervisor - 关闭主管 009e412c-0d39-400c-8302-08296524c703 11100 [Thread-10] 信息 o.a.s.e.EventManagerImp - 事件管理器中断 11102 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11103 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd97000a 11105 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd97000a 已关闭 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1027,5,main] 分配设置为 null 11105 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1028,5,main] 分配设置为 null 11105 [main] INFO o.a.s.d.s.ReadClusterState - 将 Thread[SLOT_1029,5,main] 分配设置为 null 11106 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1027,5,main] 为 EMPTY，当前为 EMPTY 11106 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1028,5,main] 为 EMPTY，当前为 EMPTY 11106 [main] INFO o.a.s.d.s.ReadClusterState - 等待线程 [SLOT_1029,5,main] 为 EMPTY，当前为 EMPTY 11106 [main] INFO o.a.s.d.s.Supervisor - 关闭主管 5daf8496-451f-43ca-b176-b16055d6183c 11106 [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 > 0x16a8e5abd97000a 读取其他数据，可能客户端已关闭套接字 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11106 [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:0:1:56896 其 sessionid 为 0x16a8e5abd97000a 11106 [Thread-14] INFO o.a.s.e.EventManagerImp - 事件管理器中断 11108 [Curator-Framework-0] 信息 o.a.s.s.o.a.c.f.i.CuratorFrameworkImpl - backgroundOperationsLoop 退出 11109 [ProcessThread(sid:0 cport:-1):] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - sessionid 的已处理会话终止：> 0x16a8e5abd97000c 11112 [main] 信息 o.a.s.s.o.a.z.ZooKeeper - 会话：0x16a8e5abd97000c 已关闭 11112 [main-EventThread] 信息 o.a.s.s.o.a.z.ClientCnxn - EventThread 关闭 11112 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 警告 o.a.s.s.o.a.z.s.NIOServerCnxn - 捕获流异常结束 org.apache.storm.shade.org.apache.zookeeper.server.ServerCnxn$EndOfStreamException：无法从客户端 sessionid > 0x16a8e5abd97000c 读取其他数据，可能客户端已关闭套接字 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:228) [storm-core-1.1.0.jar:1.1.0] 在 org.apache.storm.shade.org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:208) [storm-core-1.1.0.jar:1.1.0] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_60] 11113 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] 信息 o.a.s.s.o.a.z.s.NIOServerCnxn - 客户端 /127.0.0.1:56902 > 的已关闭套接字连接，其 sessionid 为 0x16a8e5abd97000c 11114 [main] INFO o.a.s.testing - 正在关闭进程 zookeeper 11115 [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2000] INFO o.a.s.s.o.a.z.s.NIOServerCnxnFactory - NIOServerCnxn 工厂退出运行方法 11116 [main] 信息 o.a.s.s.o.a.z.s.ZooKeeperServer - 正在关闭 11116 [main] 信息 o.a.s.s.o.a.z.s.SessionTrackerImpl - 正在关闭 11116 [main] 信息 o.a.s.s.o.a.z.s.PrepRequestProcessor - 正在关闭 11117 [main] 信息 o.a.s.s.o.a.z.s.SyncRequestProcessor - 正在关闭 11117 [SyncThread:0] 信息 o.a.s.s.o.a.z.s.SyncRequestProcessor - SyncRequestProcessor 已退出！ 11117 [ProcessThread(sid:0 cport:-1):] INFO o.a.s.s.o.a.z.s.PrepRequestProcessor - PrepRequestProcessor 退出循环！ 11117 [main] INFO o.a.s.s.o.a.z.s.FinalRequestProcessor - 请求处理器关闭完成 11118 [main] INFO o.a.s.testing - 在进程 zookeeper 中完成关闭 11118 [main] INFO o.a.s.testing - 删除临时路径 C:\Users\AKHAND~1\AppData\Local\Temp\ae4119b4-70b3-4d04-9aee-5bfae4c4775b 11203 [main] INFO o.a.s.testing - 删除临时路径 C:\Users\AKHAND~1\AppData\Local\Temp\a78b8c79-b9b3-438d-8df6-5d7bd74281fc 11215 [main] INFO o.a.s.testing - 无法删除文件：> C:\Users\AKHAND~1\AppData\Local\Temp\a78b8c79-b9b3-438d-8df6-5d7bd74281fc\version-2\log.1 11215 [main] INFO o.a.s.testing - 删除临时路径 C:\Users\AKHAND~1\AppData\Local\Temp\0e4fbadc-ad33-4577-9784-4cc163a778fa 11255 [main] INFO o.a.s.testing - 删除临时路径 C:\Users\AKHAND~1\AppData\Local\Temp\456d6b1d-eb21-4b76-98f1-a2bb44b2aa5e 12197 [SessionTracker] 信息 o.a.s.s.o.a.z.s.SessionTrackerImpl - SessionTrackerImpl 退出循环！
我无法理解客户端套接字为何关闭以及会话为何关闭？我无法让它工作。请帮忙。
【问题讨论】：
-
您能否提供运行拓扑时打印内容的完整日志？您发布的日志不是错误，它只是说客户端与 Zookeeper 断开连接。
-
我已经更新了日志，但如果这不是错误，为什么我看不到输出？
标签： java stream real-time apache-storm apache-storm-topology