Repository: incubator-nifi Updated Branches: refs/heads/NIFI-250 74d45aefb -> 85e38dc05
NIFI-250: - Setting the default name of the reporting task. Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/85e38dc0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/85e38dc0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/85e38dc0 Branch: refs/heads/NIFI-250 Commit: 85e38dc0555bf6a37ec378fc19b3a7811f8a32b3 Parents: 74d45ae Author: Matt Gilman <[email protected]> Authored: Wed Mar 11 15:40:23 2015 -0400 Committer: Matt Gilman <[email protected]> Committed: Wed Mar 11 15:40:23 2015 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/cluster/manager/impl/WebClusterManager.java | 1 + .../src/main/java/org/apache/nifi/controller/FlowController.java | 1 + 2 files changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/85e38dc0/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java index b5f3647..2b7524d 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-cluster/src/main/java/org/apache/nifi/cluster/manager/impl/WebClusterManager.java @@ -1010,6 +1010,7 @@ public class WebClusterManager implements HttpClusterManager, ProtocolHandler, C final ValidationContextFactory validationContextFactory = new StandardValidationContextFactory(this); final ReportingTaskNode taskNode = new ClusteredReportingTaskNode(task, id, processScheduler, new ClusteredEventAccess(this), bulletinRepository, controllerServiceProvider, validationContextFactory); + taskNode.setName(task.getClass().getSimpleName()); reportingTasks.put(id, taskNode); if ( firstTimeAdded ) { http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/85e38dc0/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java index 6173014..c95d646 100644 --- a/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java +++ b/nifi/nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/main/java/org/apache/nifi/controller/FlowController.java @@ -2504,6 +2504,7 @@ public class FlowController implements EventAccess, ControllerServiceProvider, R final ValidationContextFactory validationContextFactory = new StandardValidationContextFactory(controllerServiceProvider); final ReportingTaskNode taskNode = new StandardReportingTaskNode(task, id, this, processScheduler, validationContextFactory); + taskNode.setName(task.getClass().getSimpleName()); if ( firstTimeAdded ) { try (final NarCloseable x = NarCloseable.withNarLoader()) {
