Github user viazovskyi commented on the issue:

    https://github.com/apache/nifi/pull/2657
  
    @mgaido91 Adding UT I realized that just reset the flag and then return is 
not enough, because cluster state is not fully read (e.g. 
latestIdentifiersProcessed was not getting initialized) if i do return after 
yield. Please review the new commit after all checks completed. The idea is 
give the loop a chance to iterate over all read cluster' state and if processor 
should yield then exit the method after resetting the flag.


---

Reply via email to