我已经在NIFI中导入了一个新的OPCUA包。这里
而且这个处理器读数良好超过一天,但后来我得到了这个错误:
2019-06-04 15:09:17,727 ERROR [Timer-Driven Process Thread-7] d.f.fit.processors.opcua.GetOPCData GetOPCData[id=1e5f35cf-3df7-1e7d-1521-5c8fe9fbd8f6] Failed to process session due to org.apache.nifi.processor.exception.ProcessException: java.util.concurrent.ExecutionException: UaServiceFaultException: status=Bad_ServerHalted, message=The server has stopped and cannot process any requests.: org.apache.nifi.processor.exception.ProcessException: java.util.concurrent.ExecutionException: UaServiceFaultException: status=Bad_ServerHalted, message=The server has stopped and cannot process any requests.
org.apache.nifi.processor.exception.ProcessException: java.util.concurrent.ExecutionException: UaServiceFaultException: status=Bad_ServerHalted, message=The server has stopped and cannot process any requests.
at de.fraunhofer.fit.opcua.StandardOPCUAService.getValue(StandardOPCUAService.java:388)
at sun.reflect.GeneratedMethodAccessor272.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.nifi.controller.service.StandardControllerServiceInvocationHandler.invoke(StandardControllerServiceInvocationHandler.java:87)
at com.sun.proxy.$Proxy89.getValue(Unknown Source)
at de.fraunhofer.fit.processors.opcua.GetOPCData.onTrigger(GetOPCData.java:239)
at org.apache.nifi.processor.AbstractProcessor.onTrigger(AbstractProcessor.java:27)
at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode.java:1162)
at org.apache.nifi.controller.tasks.ConnectableTask.invoke(ConnectableTask.java:205)
at org.apache.nifi.controller.scheduling.TimerDrivenSchedulingAgent$1.run(TimerDrivenSchedulingAgent.java:117)
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:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
如果我使用Nifi重新启动StandardOPCUAService,我可以再次接收数据。我如何解决这个问题?如何自动重启服务?
代码中的错误是您必须与该包的作者一起解决的问题;它不是社区管理的Apache NiFi核心的一部分。
您可以使用NiFi REST API自动重新启动处理器。您可以使用浏览器的开发人员工具“记录”您将使用UI执行的操作,并查看更改处理器对象状态的网络调用。然后使用cron
或其他定时脚本方法调用此操作(如果需要,您甚至可以将其放在NiFi画布上的invokehttp
处理器中)。
我在运行FetchElasticSearch处理器时出现了奇怪的错误,下面是错误。 FetChelasticSearch[ID=F2B2FEE3-B940-4A73-8A28-0436E765C9A2]无法读取到Elasticsearch中,原因是没有配置的节点可用:[{#Transport#-1}{127.0.0.1}{localhost/127.0.0.1:9500}],这可能表示配置错误(主
我正在使用ksop2依赖***(编译'com.google.code.ksoap2-android: ksoap2-android: 3.6.0')***命中肥皂Web服务,但得到以下异常。 异常-SoapFault-故障代码:“soap:Server”faultstring:“服务器无法处理请求--- JAVA代码
我第一次在NIFI1.2中试用wait\notify处理器。在分布式缓存服务的属性中,我选择创建新服务。在该服务的属性下,我只选择运行nifi的本地服务器的主机名作为服务器主机名,所有的灯都在GO上改变。 但是当我开始使用Prozessors时,我遇到了这样一个错误:
我正在尝试使用ExecuteSQL处理器从oracle数据库中提取数据。我有一些查询,例如假设在我的oracle数据库中有15条记录。在这里,当我运行ExecuteSQL处理器时,它将作为一个流进程连续运行,并将整个记录作为一个文件存储在HDFS中,并且重复这样做。因此,在HDFS位置中会有许多文件,这些文件将从oracle db中提取已经提取的记录,并且这些文件包含相同的数据。我如何使该处理器以
我正在使用Tailfile处理器从计划每分钟运行的集群(3个节点)中获取日志。日志文件名每小时都会发生变化,我不知道应该使用哪种跟踪模式。如果我使用单个文件,它不会获取1小时后生成的新文件。如果我使用多文件,它是在文件名更改第三分钟后获取文件,这增加了文件的大小。我的文件的滚动文件名应该是什么,我应该使用哪种模式。你能让我知道吗。谢谢。 tail:retrieve-${now():format(“
问题内容: 我有一个新编码的GWT / GAE应用,该应用在客户端上使用RequestFactory和Editors,在背面使用自定义的Objectify DAO服务。 flush()然后persist()路径在成功时可以正常工作。客户端JSR 303也可以正常工作。 我的问题是如何触发服务器警告/错误并处理UI更新? 我在http://turbomanage.wordpress.com/2010