You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

ListAzureBlobStorage从ZooKeeper取值失败问题求助

问题描述

ListAzureBlobStorage此前配置正常(配置截图:ListAzureBlobStorage配置),未做任何更改的情况下突然报错。已重启NiFi并重新设置所有属性,问题仍未解决。查阅相关类似问题后,未找到有效解决方案。

错误信息

ListAzureBlobStorage[id=34c1ea1d-0186-1000-aad1-11c9a28c4c83] Failed to properly initialize Processor. If still scheduled to run, NiFi will attempt to initialize and run the Processor again after the 'Administrative Yield Duration' has elapsed. Failure is due to java.io.IOException: Failed to obtain value from ZooKeeper for component with ID 34c1ea1d-0186-1000-aad1-11c9a28c4c83 with exception code CONNECTIONLOSS: org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for /nifi/components/34c1ea1d-0186-1000-aad1-11c9a28c4c83
↳ causes: java.io.IOException: Failed to obtain value from ZooKeeper for component with ID 34c1ea1d-0186-1000-aad1-11c9a28c4c83 with exception code CONNECTIONLOSS

排查与解决方向
  • 检查ZooKeeper集群状态
    登录ZooKeeper节点,执行zkServer.sh status查看每个节点的运行状态,确认是否有节点宕机、出现网络分区。集群模式下需保证法定数量节点正常运行。
  • 验证NiFi与ZooKeeper的网络连通性
    在NiFi节点上用telnet <zk-host> <zk-port>或nc -zv <zk-host> <zk-port>测试端口连通性,排查防火墙、安全组是否阻断了两者的通信。
  • 清理ZooKeeper中该组件的残留数据
    若ZooKeeper中该处理器的节点数据损坏,可登录ZooKeeper客户端,执行delete /nifi/components/34c1ea1d-0186-1000-aad1-11c9a28c4c83删除残留节点,之后重启NiFi节点重新初始化。
  • 核对NiFi的ZooKeeper配置
    检查nifi.properties中的ZooKeeper连接配置(如nifi.zookeeper.connect.string、nifi.zookeeper.session.timeout等),确认配置未被意外修改,尤其是连接字符串是否包含所有可用ZooKeeper节点。
  • 查看日志细节定位根因
    检查ZooKeeper的zookeeper.out或日志目录下的日志,以及NiFi的nifi-app.log,查找连接断开的具体触发原因,比如超时、认证失败、资源不足等。
  • 临时替换处理器测试
    若以上方法均无效,可尝试删除当前的ListAzureBlobStorage处理器,重新创建一个新的并配置相同参数,测试是否能正常运行。

内容的提问来源于stack exchange,提问作者vasanth

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.01 04:50:25