程序员经验分享-hwhale

如何使用wait\notify处理器？

2023-12-23

我正在运行 nifi 实例 1.2.0。

我只是尝试使用“Wait\Notify”处理器并参考以下内容http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice http://ijokarumawak.github.io/nifi/2017/02/02/nifi-notify-batch/#why-mergecontent-dont-suffice

将模板拖动到画布中，我尝试运行它。

它显示以下错误“等待/通知”处理器。

Unable to communicate with cache when processing StandardFlowFileRecord[uuid=faab337f-034c-4137-a2f3-abb46f22b474,claim=StandardContentClaim [resourceClaim=StandardResourceClaim[id=1494485406343-1, container=default, section=1], offset=0, length=7005603],offset=5280310,name=input.csv,size=1054261] due to java.net.ConnectException: Connection refused: connect:

我不知道这个错误说明了什么？

我没有在 1.2.0 中应用任何补丁，我只是下载了二进制文件并尝试了它

如果我错过了什么，请阻止我？

并指导我解决这个问题。


您将需要创建并启动 DistributedMapCacheServer 和 DistributedMapCacheClient。客户端需要配置服务器正在侦听的端口和主机。

然后等待和通知处理器使用DistributedMapCacheClient。

由于您能够启动处理器，因此您可能已经设置了客户端，但尚未运行服务器。

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

apachenifi

如何使用wait\notify处理器？ 的相关文章

  • PublishJMS 处理器无法将消息写入 IBM Websphere MQ

    我在通过 PublishJMS 处理器将消息发布到 IBM Websphere MQ 队列时遇到问题 配置PublishJMS处理器和JMS控制器服务 我已经验证MQ连接没有问题 我相信我需要在 PublishJMS 或控制器服务中设置一些

  • Nifi：nifi 中的线程

    我想知道线程在 nifi 中如何工作 我的意思是一个处理器有一个线程还是它们在一个主线程中 也许我想从处理器获取一个文件 然后我想更新它 如何防止多个处理器同时获取文件数据 除了使用 keep file false 操作 是否可以在执行脚本

  • Nifi PutSQL Timestamp/Datetime错误无法转换错误

    我尝试了建议的解决方案 通过使用 UpdateAttribute 处理器来消除时间戳格式转换错误 即 将JSON转换为SQL gt UpdateAttribute gt PutSQL 在 UpdateAttribute 中我使用了 Prop

  • SQL Server 的 DBCPConnectionPool 控制器服务，jdbc 异常

    NiFi 1 1 1 在 Windows 7 和 RHEL 7 上进行了测试 后台线程是here https stackoverflow com questions 42765471 jdbc failing in custom proce

  • Nifi 处理器无法正确解析 JSON

    我正在使用 EvaluateJsonPath 从 JSON 中提取一个特定值 我正在使用以下 JSONPath 表达式 data containerType SOURCE path SOURCE KYLO DATALAKE id 这是我调用

  • 为时间戳记录创建正确的 avro 架构

    我想知道对于这种格式的 json 到 avro 转换 正确的 avro 模式是什么 entryDate 2018 01 26T12 00 40 930 我的架构 type record name schema fields name ent

  • Nifi：如何使 ListenHTTP 与 SSL 配合使用

    客观的 由于 Nifi 通过 HTTP 与其他工具集成 我必须ListenHTTP处理器面向公众 所有 3 个环境上的 API 网关对我来说太贵了 所以我关闭了所有虚拟机入口端口 除了ListenHTTP 对于外部网络 Issue 我的配置

  • 如何使用 NiFi 将字符串转换为 JSON 数组

    在 NiFi 中 我正在处理包含以下属性的流文件 Key my array Value u firstElement u secondElement 我想在此数组上拆分 flowFile 以单独处理每个元素 然后合并 我尝试使用SplitJ

  • 自动化 NIFI 模板部署

    我是 nifi 的新手 我试图了解 因为它看起来很多基于 GUI 是否有一种方法可以在 Nifi 上自动扩展和缩减 以及如何采用 xml Nifi 模板并将其部署到集群 本质上 我们想做的是使用 Nifi 从 kafka 服务器收集 JMX

  • Apache Nifi：使用更新记录处理器替换列中的值

    我有一个 csv 看起来像这样 name code age Himsara 9877 12 John 9437721 16 Razor 232 45 我必须更换色谱柱code根据一些正则表达式 我的逻辑如下面的 Scala 代码所示 if

  • Apache NiFi - OutOfMemory 错误：SplitText 处理器上超出了 GC 开销限制

    我正在尝试使用 NiFi 使用 HDF 1 2 处理大型 CSV 文件 每个文件可能有数十亿条记录 我已经实现了我的流程 对于小文件来说一切正常 问题是 如果我尝试将文件大小增加到 100MB 1M 记录 我会得到一个java lang O

  • Nifi DistributedCache查找问题

    我配置了一个流程如下 GetFile SplitText gt 分割成流文件 ExtractText gt 使用两个键添加属性 PutDistributedMapCache gt 缓存条目标识符是 Key1 Key2 现在我配置了一个示例G

  • NiFi：ReplaceTextWithMapping 处理器

    我有以下插入语句 insert into temp1 values test1 test2 insert into temp2 values test3 预期成绩 insert into temp1 values 100 200 inser

  • Apache NIFI Jon 不会自动终止

    我是 Apache NIFI 工具的新手 我正在尝试从 mongo db 导入数据并将该数据放入 HDFS 中 我创建了 2 个处理器 第一个用于 MongoDB 第二个用于 HDFS 并且我正确配置了它们 该作业正在成功运行并将数据存储到

  • NiFi：ExtractText 中的正则表达式获取 CSV 标头而不是数据

    我正在开发一个获取 CSV 文件的流程 我想根据 CSV 记录中的第一个字段将记录放入不同的目录中 例如 CSV 文件看起来像这样 country firstname lastname ssn mob num US xxxx xxxxx x

  • 在nifi中将JSON转换为CSV

    我想在 nifi 中将 JSON 文件转换为 CSV 我们可以用 Python 和其他编程语言来实现这一点 并且有多篇文章介绍它 我有多个 JSON 文件 每个文件都有不同的架构 一个特定文件只有一个架构 我可以看到有一些模板可以将 CSV

  • NiFi 如何将 InvokeHTTP 处理器与 SOAP 结合使用

    我看到其他人已经能够使其发挥作用 但是我无法找到足够的详细信息来解释他们如何实现这一目标 以便我能够使其发挥作用 This guy http apache nifi developer list 39713 n7 nabble com SO

  • 在 Nifi 中使用“DBCPConnectionPoolLookup”服务时出现异常“无法获取连接，池错误超时等待空闲对象”

    我正在尝试使用 ExecuteGroovyScript 中的 DBCPConnectionPoolLookup 服务根据输入流文件中的 database name 参数动态查询所需的数据库 处理器能够成功获取相应的 DBCPConnecti

  • 通过 REST 发布 NIFI 模板？

    我有多个 nifi 服务器 我希望能够通过脚本的 REST 接口将模板发布到这些服务器 The controller templates endpoint appears to be the proper REST endpoint to

  • NIFI如何将uuid更改为文件名

    我将一些 XML 格式的文档加载到 Marklogic 中 PutMarkLogic URI 属性的Name 属性默认为 uuid 我怎样才能将其更改为文件名 输入目录 input ac01010 xml input ac02010 xml

随机推荐

  • 如何解决没有 xargs -d 的 MacOS X 问题？

    我有以下命令 xargs d n n 8 bash c phpcs element PSR2 1 2 3 4 5 6 7 8 gt 2 2 gt dev null 如果我在 Linux 中运行此命令 它会起作用 如果我尝试在 Mac OSX

  • Apiary：是否可以记录 JSON 响应字段是什么？

    我想记录实际的 JSON 字段本身代表什么 我已经记录了 GET 语句和参数 但这并不能提供给用户的完整文档 那么 在下面的示例中 我将如何添加有关 OtherFields 的注释 支持吗 或者我是否需要在其他地方制作一份配套文档 View

  • GStreamer：将虚拟音轨添加到接收的 rtp 流中

    我正在使用以下命令从 Raspberry 相机启动 RTP 流 raspivid n vf fl t 0 w 640 h 480 b 1200000 fps 20 pf baseline o gst launch 1 0 v fdsrc h

  • 获取 Span 文本的值

    我有一个跨度class span 和一个隐藏字段class dropdown The span文本发生变化 我需要抓取文本并将其设置为隐藏字段值的值 然后我将使用 php 我已经有了 并使用隐藏字段的名称通过电子邮件将文本发送给我 我该怎么

  • 在 .app 运行时触发脚本（AppleScript 或 JXA）？

    我有一个小型计算机实验室 供学生在无人监督的情况下使用 并在网络上连接了打印机 我正在尝试实现一个简单的脚本添加警报对话框 其中包含有关打印机的所有规则 当他们从任意数量的不同应用程序中选择打印时 我需要弹出这些规则 我正在尝试将脚本直接附

  • 禁用 JButton 的空格键触发单击

    JButton 认为按空格键与单击 JButton 相同 假设 JButton 具有焦点 我在这里假设 有没有办法关闭这种行为 让他们忽略按空格键 另外 更一般地说 是否有一种技术可以做到这一点AbstractButtons 您可以通过执行

  • 删除默认构造函数仍然是微不足道的？

    查看标准中普通默认构造函数的定义 如果默认构造函数不是用户提供的并且满足以下条件 则它是微不足道的 它的类没有虚函数 10 3 也没有虚基类 10 1 并且 其类的非静态数据成员没有大括号或等于初始化程序 并且 其类的所有直接基类都有简单的

  • 如果用户有 cookie javascript 如何重定向用户

    我需要知道当用户第一次使用 javascript 访问该页面时如何为他们提供 cookie 然后我需要 cookie 在 1 小时内过期 如果 cookie 仍然存在并且他们尝试在 1 小时结束之前访问该页面 那么它会重定向他们 相关解决方

  • HTML5 视频的图像占位符备用

    我使用以下代码在页面上实现 HTML5 视频

  • .NET System.Diagnostics.Stopwatch 问题（返回值太低）

    在我的计算机上 秒表返回的值太低 例如 当我指定时为 200 毫秒Thread Sleep 1000 该程序应该等待 1 秒 我也测试过ManualResetEvent WaitOne 1000 并得到相同的结果 框架 2 0 和 3 0

  • SQL 中的排除语句

    如何使用SQL语句从SQL数据库中排除数据 我的情况是 我有一个用户登录到他们的个人资料页面 他们可以在其中与人交友 我想显示在 SQL 数据库中找到的除他们自己之外的所有用户 也许只是 SELECT FROM Users WHERE Us

  • 如何创建一个迭代器来生成项目，其中没有项目的单个字符在 python 中表示超过 n 次？

    我创建了一个脚本 它使用以下代码来迭代 sCharacters 字符串中的所有字符组合 sCharacters abcdefghijklmnopqrstuvwxyz0123456789 iKeyLength len sCharacters

  • 如果 PostgreSQL 上不存在如何添加列？

    问题很简单 如何添加列x到餐桌y 但仅当x列不存在 我找到了唯一的解决方案here https stackoverflow com questions 9991043 how can i test if a column exists in

  • nginx代理通过Node，SSL？

    我的 nginx 服务器实际上是用一个简单的方法代理我的节点后端 监听端口 3000 location api proxy pass http upstream 1 其中upstream 1是我在nginx conf中定义的节点集群 在端口

  • 什么是跟踪分支？

    有人可以解释一下适用于 git 的 跟踪分支 吗 这是来自的定义git scm com https git scm com book en v2 Git Branching Remote Branches Git 中的 跟踪分支 是本地分支

  • 继承：选择继承哪些基类方法[关闭]

    Closed 这个问题需要细节或清晰度 help closed questions 目前不接受答案 我有课Base并想写一个类Derive它仅继承了部分成员函数Base 有什么方便的方法可以做到这一点吗 例如 class Base void

  • 在 C# 中访问简单的布尔标志时，是否需要锁定或标记为易失性？

    假设您有一个在后台线程上运行的简单操作 您希望提供一种方法来取消此操作 因此您创建一个布尔标志 并从取消按钮的单击事件处理程序将其设置为 true private bool cancelled private void CancelButt

  • 如何将 Material UI 中的组件居中并使其具有响应能力？

    我不太了解 Material UI 网格系统 如果我想使用表单组件进行登录 在所有设备 移动设备和桌面设备 上将其置于屏幕中央的最简单方法是什么 因为您将在登录页面上使用它 这是我在使用 Material UI 的登录页面中使用的代码 材质

  • Pyspark - 多列聚合

    我有如下数据 文件名 babynames csv year name percent sex 1880 John 0 081541 boy 1880 William 0 080511 boy 1880 James 0 050057 boy

  • 如何使用wait\notify处理器？

    我正在运行 nifi 实例 1 2 0 我只是尝试使用 Wait Notify 处理器并参考以下内容http ijokarumawak github io nifi 2017 02 02 nifi notify batch why merg

热门标签