apache-nifi - Nifi站点到站点
问题描述
我正在尝试在 2 个 Nifi 服务器之间创建站点到站点的连接。Nifi1(主机名 wef2 - 在 Windows 上运行)需要将流量传送到 nifi2(IP 10.168.233.168 - 在 linux 上运行) - 我定义了连接并且一切都是绿色的,但是在 Nifi1 上我收到以下错误消息
*port ID 0176100c-8d25-196b-1f72-6befa5cab12a 是 NIFI2 中的输入端口
**2020-12-01 01:54:13,508 INFO [pool-12-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 2 records in 0 milliseconds
2020-12-01 01:54:20,677 INFO [Http Site-to-Site PeerSelector] o.apache.nifi.remote.client.PeerSelector Successfully refreshed peer status cache; remote group consists of 2 peers
2020-12-01 01:54:23,203 WARN [Timer-Driven Process Thread-3] o.a.nifi.remote.client.http.HttpClient Penalizing a peer Peer[url=http://localhost:8080/nifi-api] due to java.io.IOException: Unexpected response code: 404 errCode:Abort errMessage:Unable to find port with id '0176100c-8d25-196b-1f72-6befa5cab12a'.
2020-12-01 01:54:23,208 WARN [Timer-Driven Process Thread-3] o.a.nifi.remote.client.http.HttpClient Penalizing a peer Peer[url=http://wef2:8080/nifi-api] due to java.io.IOException: Unexpected response code: 404 errCode:Abort errMessage:Unable to find port with id '0176100c-8d25-196b-1f72-6befa5cab12a'.
2020-12-01 01:54:23,208 INFO [Timer-Driven Process Thread-3] o.a.nifi.remote.client.http.HttpClient Couldn't find a valid peer to communicate with.
2020-12-01 01:54:33,214 WARN [Timer-Driven Process Thread-2] o.a.nifi.remote.client.http.HttpClient Penalizing a peer Peer[url=http://wef2:8080/nifi-api] due to java.io.IOException: Unexpected response code: 404 errCode:Abort errMessage:Unable to find port with id '0176100c-8d25-196b-1f72-6befa5cab12a'.
2020-12-01 01:54:33,219 WARN [Timer-Driven Process Thread-2] o.a.nifi.remote.client.http.HttpClient Penalizing a peer Peer[url=http://localhost:8080/nifi-api] due to java.io.IOException: Unexpected response code: 404 errCode:Abort errMessage:Unable to find port with id '0176100c-8d25-196b-1f72-6befa5cab12a'.
2020-12-01 01:54:33,219 INFO [Timer-Driven Process Thread-2] o.a.nifi.remote.client.http.HttpClient Couldn't find a valid peer to communicate with.
2020-12-01 01:54:33,510 INFO [pool-12-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Initiating checkpoint of FlowFile Repository
2020-12-01 01:54:33,510 INFO [pool-12-thread-1] o.a.n.c.r.WriteAheadFlowFileRepository Successfully checkpointed FlowFile Repository with 2 records in 0 milliseconds**
尼菲 1
尼菲 2
远程进程
远程进程配置
解决方案
我已经使用以下参数更新了 nifi.proporties 文件
在 # Site to Site properties 部分下更新以下行 nifi.remote.input.host = nifi.remote.input.socket.port= 10000
推荐阅读
- c# - c# - 在字符串内的数组中插入预定义值
- excel - 如何添加第三个范围以进行协调?
- javascript - 如何重用我的代码在点击时打开 Accordions
- python-3.x - 带日志记录的密码生成器
- pandas - 将行添加到 DataFrame,但与某些列的预先存在的行具有相同的值
- cmake - CMake:用于复制与模式匹配的文件并保留目录结构的自定义命令
- mysql - 从 date_of_birth 获取年龄大于 35 的年龄
- java - java项目中集成测试的最佳文件夹约定
- c++ - 如何从文件中读取并存储在c ++中的对象数组中
- laravel - Laravel-excel 无法更新记录“WithUpserts” - 未找到