NIFI-4394 Fixed CPU issue - gRPC

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

This closes #2163.
This commit is contained in:
Sébastien Bouchex Bellomié 2017-09-19 09:42:03 +02:00 committed by Pierre Villard
parent 66479464be
commit 2ee21b9255
1 changed files with 1 additions and 0 deletions

View File

@ -242,5 +242,6 @@ public class ListenGRPC extends AbstractSessionFactoryProcessor {
@Override @Override
public void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException { public void onTrigger(ProcessContext context, ProcessSessionFactory sessionFactory) throws ProcessException {
sessionFactoryReference.compareAndSet(null, sessionFactory); sessionFactoryReference.compareAndSet(null, sessionFactory);
context.yield();
} }
} }