[ 
https://issues.apache.org/jira/browse/NIFI-78?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15176522#comment-15176522
 ] 

Mark Payne commented on NIFI-78:
--------------------------------

I think one thing that we need to be sure to consider here, is what happens 
after we interrupt a Processor, wrt the ProcessSession's. For example, if the 
processor has a Session already, and it's interrupted, we should ensure that 
the Processor can't access any FlowFiles. I.e., we need the ability to 
invalidate all sessions for that Processor. This would probably involve 
something like an invalidate() method being added to ProcessSession, and it 
would mean that we must have an invalidate() method on ProcessSessionFactory. 
ProcessSessionFactory should then delegate this to all Sessions that have been 
created by it (should probably use a Weak Reference type of data structure so 
that we can keep track of all sessions that have been created without 
preventing GC from reclaiming it)

> Add interrupt option for stopped processors with active threads
> ---------------------------------------------------------------
>
>                 Key: NIFI-78
>                 URL: https://issues.apache.org/jira/browse/NIFI-78
>             Project: Apache NiFi
>          Issue Type: Improvement
>          Components: Core Framework
>            Reporter: Joseph Witt
>            Assignee: Oleg Zhurakousky
>            Priority: Minor
>             Fix For: 0.6.0
>
>
> Some processors have really long stopping periods.  Would be nice to be able 
> to forcibly kill them if possible.  Otherwise certain flow changes cannot 
> occur.  This is one part best practices and another part helping the user 
> decide when to forcibly kill a processor.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to