我第一次尝试在Nifi 1.2中使用Wait\Notify处理器。在分布式缓存服务的属性中,我选择创建新服务。(Wait.java:354) at org.apache.nifi.controller.StandardProcessorNode.onTrigger(StandardProcessorNode
我集成了两个工具ApacheNiFi和Apache Flink。NiFi获取事件并将它们发送到Flink,之后Flink将这些事件经过一些处理返回给相同的NiFi。我在Flink中构建了Nifi的源代码和接收器。整个过程可以工作,但是接收器的性能非常差(大约每秒10个事件)。
SiteToSiteClientConfig sinkConfig = new Si