From 2ee21b9255f8188b2843314e7fc0bcd0e7bb7bb8 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?S=C3=A9bastien=20Bouchex=20Bellomi=C3=A9?=
 <sbouchex@infovista.com>
Date: Tue, 19 Sep 2017 09:42:03 +0200
Subject: [PATCH] NIFI-4394 Fixed CPU issue - gRPC

Signed-off-by: Pierre Villard <pierre.villard.fr@gmail.com>

This closes #2163.
---
 .../main/java/org/apache/nifi/processors/grpc/ListenGRPC.java    | 1 +
 1 file changed, 1 insertion(+)

diff --git a/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java b/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java
index b0e703577b..72d9aff445 100644
--- a/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java
+++ b/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java
@@ -242,5 +242,6 @@ public class ListenGRPC extends AbstractSessionFactoryProcessor {
     @Override
     public void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException {
         sessionFactoryReference.compareAndSet(null, sessionFactory);
+        context.yield();
     }
 }