You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2017/09/19 15:38:24 UTC
nifi git commit: NIFI-4394 Fixed CPU issue - gRPC
Repository: nifi
Updated Branches:
refs/heads/master 66479464b -> 2ee21b925
NIFI-4394 Fixed CPU issue - gRPC
Signed-off-by: Pierre Villard <pi...@gmail.com>
This closes #2163.
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2ee21b92
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2ee21b92
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2ee21b92
Branch: refs/heads/master
Commit: 2ee21b9255f8188b2843314e7fc0bcd0e7bb7bb8
Parents: 6647946
Author: Sébastien Bouchex Bellomié <sb...@infovista.com>
Authored: Tue Sep 19 09:42:03 2017 +0200
Committer: Pierre Villard <pi...@gmail.com>
Committed: Tue Sep 19 17:37:21 2017 +0200
----------------------------------------------------------------------
.../src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/2ee21b92/nifi-nar-bundles/nifi-grpc-bundle/nifi-grpc-processors/src/main/java/org/apache/nifi/processors/grpc/ListenGRPC.java
----------------------------------------------------------------------
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 b0e7035..72d9aff 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();
}
}