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

NIFI-1577: Close any streams that are left open for 'append' when the session is checkpointed, rather than waiting for it to be committed

This commit is contained in:
Mark Payne 2016-02-29 16:02:26 -05:00
parent 62333c9e0a
commit 6776060ac8
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -180,6 +180,8 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
} }
public void checkpoint() { public void checkpoint() {
resetWriteClaims(false);
if (!recursionSet.isEmpty()) { if (!recursionSet.isEmpty()) {
throw new IllegalStateException(); throw new IllegalStateException();
} }
@ -287,7 +289,6 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
try { try {
final long commitStartNanos = System.nanoTime(); final long commitStartNanos = System.nanoTime();
resetWriteClaims(false);
resetReadClaim(); resetReadClaim();
final long updateProvenanceStart = System.nanoTime(); final long updateProvenanceStart = System.nanoTime();