Nifi选择等待服务器\通知处理器
我第一次在NIFI1.2中试用wait\notify处理器。在分布式缓存服务的属性中，我选择创建新服务。在该服务的属性下，我只选择运行nifi的本地服务器的主机名作为服务器主机名，所有的灯都在GO上改变。
但是当我开始使用Prozessors时，我遇到了这样一个错误：
2017-07-12 14:28:09,563 ERROR [Timer-Driven Process Thread-6]
org.apache.nifi.processors.standard.Wait
Wait[id=115238a2-299b-1267-98b6-14d1a4eb45e8] Failed to process
session due to org.apache.nifi.processor.exception.ProcessException:
Failed to get signal for TOC_2017cw14_WGS84_umts due to
java.net.ConnectException: Connection refused: {}
org.apache.nifi.processor.exception.ProcessException: Failed to get
signal for TOC_2017cw14_WGS84_umts due to java.net.ConnectException:
Connection refused
at org.apache.nifi.processors.standard.Wait.onTrigger(Wait.java:354)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1120)
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:147)
at org.apache.nifi.controller.tasks.ContinuallyRunProcessorTask.call(ContinuallyRunProcessorTask.java:47)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:132)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.net.ConnectException: Connection refused
at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
at sun.nio.ch.SocketAdaptor.connect(SocketAdaptor.java:111)
共有1个答案
使用默认参数（端口4557）手动添加DistributedMapCacheServer并启用它。
您可能有DistributedMapCacheClientService，但是您需要DistributedMapCacheServer来解决此问题。
-
前端是vue.js 后端是php服务器 需求：在vue里post服务器。获得服务器php页面的返回值。
-
问题内容： 据我所知，并已替换为更好的并发机制。那么，对于实现同步队列，您会选择哪种更好的替代方法呢？ 它们究竟在什么意义上“更好”？ 编辑 ：这（“实现同步队列”）是一个采访问题。可接受的答案不能使用BlockingQueue或其他队列实现。但是，它可能使用其他同步构造，例如CountDownLatch。我没有允许和禁止的类的详尽列表- 请您注意。 问题答案： 已被Lock类方法和Conditi
-
我正在写一段代码来登录Gmail。在密码页面上，我不是使用隐式等待，而是想改用显式等待。然而，它不是拿起我的选择器？ 我得到了一个错误： （节点：14428）UnhandledPromiseRejectionWarning：错误：processTicksAndRejections(internal/process/next_tick.js:81:5)处的elementHandle._clickab
-
我正在尝试使用ExecuteSQL处理器从oracle数据库中提取数据。我有一些查询，例如假设在我的oracle数据库中有15条记录。在这里，当我运行ExecuteSQL处理器时，它将作为一个流进程连续运行，并将整个记录作为一个文件存储在HDFS中，并且重复这样做。因此，在HDFS位置中会有许多文件，这些文件将从oracle db中提取已经提取的记录，并且这些文件包含相同的数据。我如何使该处理器以
-
我正在使用Tailfile处理器从计划每分钟运行的集群（3个节点）中获取日志。日志文件名每小时都会发生变化，我不知道应该使用哪种跟踪模式。如果我使用单个文件，它不会获取1小时后生成的新文件。如果我使用多文件，它是在文件名更改第三分钟后获取文件，这增加了文件的大小。我的文件的滚动文件名应该是什么，我应该使用哪种模式。你能让我知道吗。谢谢。 tail：retrieve-${now（）：format（“
-
我编写了一个自定义的NiFi处理器，用于在BigQuery上执行一些任务。我希望能够重用与NiFi捆绑在一起的GCP凭据提供者控制器服务，以用于身份验证。这可能吗？我尝试将nifi-gcp-processors maven依赖项添加到我的项目中，它成功构建，但当我尝试用我的nar启动NiFi时，它失败了，出现了这个错误消息。