This commit is contained in:
Mark Payne 2014-12-12 11:09:52 -05:00
parent 67354bd31c
commit a8722317ab
1 changed files with 1 additions and 1 deletions

View File

@ -479,7 +479,7 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE
context.getFlowFileEventRepository().updateRepository(flowFileEvent); context.getFlowFileEventRepository().updateRepository(flowFileEvent);
for (final FlowFileEvent connectionEvent : connectionCounts.values()) { for (final FlowFileEvent connectionEvent : checkpoint.connectionCounts.values()) {
context.getFlowFileEventRepository().updateRepository(connectionEvent); context.getFlowFileEventRepository().updateRepository(connectionEvent);
} }
} catch (final IOException ioe) { } catch (final IOException ioe) {