Repository: nifi Updated Branches: refs/heads/master 6a8c2dba1 -> 663b7f256
NIFI-1243 This closes #137. added null check for 'currentReadClaimStream' . . .before it is being closed Signed-off-by: joewitt <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/663b7f25 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/663b7f25 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/663b7f25 Branch: refs/heads/master Commit: 663b7f2561424ee9a9ce7070d783f63854e698b2 Parents: 6a8c2db Author: Oleg Zhurakousky <[email protected]> Authored: Wed Dec 2 16:13:46 2015 -0500 Committer: joewitt <[email protected]> Committed: Wed Dec 2 16:23:48 2015 -0500 ---------------------------------------------------------------------- .../apache/nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/663b7f25/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java index 6ad65c1..22fee7f 100644 --- a/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java +++ b/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java @@ -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; }
