This commit is contained in:
Mark Payne 2015-12-02 17:41:18 -05:00
commit 69598a0b40
1 changed files with 1 additions and 1 deletions

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;
}