Repository: nifi Updated Branches: refs/heads/master 62333c9e0 -> 6776060ac
NIFI-1577: Close any streams that are left open for 'append' when the session is checkpointed, rather than waiting for it to be committed Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/6776060a Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/6776060a Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/6776060a Branch: refs/heads/master Commit: 6776060ac80e4b47d0fadede3c7a5873fd9e374f Parents: 62333c9 Author: Mark Payne <marka...@hotmail.com> Authored: Mon Feb 29 16:02:26 2016 -0500 Committer: Mark Payne <marka...@hotmail.com> Committed: Mon Feb 29 16:02:26 2016 -0500 ---------------------------------------------------------------------- .../apache/nifi/controller/repository/StandardProcessSession.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/6776060a/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 d2ba55d..cb789e2 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 @@ -180,6 +180,8 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE } public void checkpoint() { + resetWriteClaims(false); + if (!recursionSet.isEmpty()) { throw new IllegalStateException(); } @@ -287,7 +289,6 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE try { final long commitStartNanos = System.nanoTime(); - resetWriteClaims(false); resetReadClaim(); final long updateProvenanceStart = System.nanoTime();
