Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

NIFI-1243 This closes #137. added null check for 'currentReadClaimStream' . . .before it is being closed 

Signed-off-by: joewitt <joewitt@apache.org>
This commit is contained in:
Oleg Zhurakousky 2015-12-02 16:13:46 -05:00 committed by joewitt
parent 6a8c2dba12
commit 663b7f2561
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java
View File

@ -1806,7 +1806,7 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
reader.process(ffais);
// Allow processors to close the file after reading to avoid too many files open or do smart session stream management.
if(!allowSessionStreamManagement){
if (this.currentReadClaimStream != null && !allowSessionStreamManagement) {
currentReadClaimStream.close();
currentReadClaimStream = null;
}