Repository: nifi Updated Branches: refs/heads/master c0dad8d1d -> 740b09b18
NIFI-796 Adjusting ControlRate documentation to reflect that a long is used instead of an integer. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/740b09b1 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/740b09b1 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/740b09b1 Branch: refs/heads/master Commit: 740b09b182a2b5f2c8530336df6c7c788e73700d Parents: c0dad8d Author: Aldrin Piri <[email protected]> Authored: Mon Aug 17 11:51:10 2015 -0400 Committer: Aldrin Piri <[email protected]> Committed: Mon Aug 17 11:51:10 2015 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ControlRate.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/740b09b1/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ControlRate.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ControlRate.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ControlRate.java index 47c3cb4..2efc852 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ControlRate.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ControlRate.java @@ -79,7 +79,7 @@ public class ControlRate extends AbstractProcessor { public static final PropertyDescriptor RATE_CONTROL_ATTRIBUTE_NAME = new PropertyDescriptor.Builder() .name("Rate Controlled Attribute") .description("The name of an attribute whose values build toward the rate limit if Rate Control Criteria is set to 'attribute value'. " - + "The value of the attribute referenced by this property must be a positive integer, or the FlowFile will be routed to failure. " + + "The value of the attribute referenced by this property must be a positive long, or the FlowFile will be routed to failure. " + "This value is ignored if Rate Control Criteria is not set to 'attribute value'. Changing this value resets the rate counters.") .required(false) .addValidator(StandardValidators.NON_EMPTY_VALIDATOR) @@ -249,7 +249,7 @@ public class ControlRate extends AbstractProcessor { } if (!POSITIVE_LONG_PATTERN.matcher(attributeValue).matches()) { - logger.error("routing {} to 'failure' because FlowFile attribute {} has a value of {}, which is not a positive integer", + logger.error("routing {} to 'failure' because FlowFile attribute {} has a value of {}, which is not a positive long", new Object[]{flowFile, rateControlAttributeName, attributeValue}); session.transfer(flowFile, REL_FAILURE); return;
