From a8722317abdbf28e86d3d4ed91e18d2f3ac2a40a Mon Sep 17 00:00:00 2001 From: Mark Payne Date: Fri, 12 Dec 2014 11:09:52 -0500 Subject: [PATCH] NIFI-66: --- .../nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java b/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java index 11172a8f54..fbbb29b2d4 100644 --- a/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java +++ b/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java @@ -479,7 +479,7 @@ public final class StandardProcessSession implements ProcessSession, ProvenanceE context.getFlowFileEventRepository().updateRepository(flowFileEvent); - for (final FlowFileEvent connectionEvent : connectionCounts.values()) { + for (final FlowFileEvent connectionEvent : checkpoint.connectionCounts.values()) { context.getFlowFileEventRepository().updateRepository(connectionEvent); } } catch (final IOException ioe) {