Repository: incubator-nifi Updated Branches: refs/heads/develop 67354bd31 -> a8722317a
NIFI-66: Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/a8722317 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/a8722317 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/a8722317 Branch: refs/heads/develop Commit: a8722317abdbf28e86d3d4ed91e18d2f3ac2a40a Parents: 67354bd Author: Mark Payne <[email protected]> Authored: Fri Dec 12 11:09:52 2014 -0500 Committer: Mark Payne <[email protected]> Committed: Fri Dec 12 11:09:52 2014 -0500 ---------------------------------------------------------------------- .../apache/nifi/controller/repository/StandardProcessSession.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/a8722317/nar-bundles/framework-bundle/framework/core/src/main/java/org/apache/nifi/controller/repository/StandardProcessSession.java ---------------------------------------------------------------------- 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 11172a8..fbbb29b 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) {
