This is an automated email from the ASF dual-hosted git repository.
pvillard31 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new c31dc1f2d84 NIFI-16534 Fixed typos in extension component descriptions
(#11882)
c31dc1f2d84 is described below
commit c31dc1f2d84274e3929a49443380631ceac3f02a
Author: Anshu Singh <[email protected]>
AuthorDate: Tue Nov 3 22:21:10 2026 +0530
NIFI-16534 Fixed typos in extension component descriptions (#11882)
---
.../src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java | 2 +-
.../java/org/apache/nifi/processors/aws/AbstractAwsProcessor.java | 2 +-
.../loganalytics/AzureLogAnalyticsProvenanceReportingTask.java | 2 +-
.../apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java | 2 +-
.../src/main/java/org/apache/nifi/processors/GeoEnrichIP.java | 2 +-
.../src/main/java/org/apache/nifi/processors/ISPEnrichIP.java | 2 +-
.../apache/nifi/processor/util/file/transfer/PutFileTransfer.java | 2 +-
.../src/main/java/org/apache/nifi/processors/hadoop/ListHDFS.java | 2 +-
.../java/org/apache/nifi/jms/processors/AbstractJMSProcessor.java | 2 +-
.../src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java | 6 +++---
.../java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java | 2 +-
.../producer/transaction/KafkaTransactionalProducerWrapper.java | 2 +-
.../java/org/apache/nifi/processors/media/ExtractMediaMetadata.java | 4 ++--
.../java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java | 2 +-
.../src/main/java/org/apache/nifi/processors/splunk/GetSplunk.java | 2 +-
.../java/org/apache/nifi/processors/standard/AttributesToJSON.java | 2 +-
.../main/java/org/apache/nifi/processors/standard/DeleteSFTP.java | 2 +-
.../main/java/org/apache/nifi/processors/standard/ExtractText.java | 2 +-
.../main/java/org/apache/nifi/processors/standard/ListenHTTP.java | 2 +-
.../java/org/apache/nifi/processors/standard/LookupAttribute.java | 2 +-
.../main/java/org/apache/nifi/processors/standard/QueryRecord.java | 2 +-
.../main/java/org/apache/nifi/processors/standard/RouteText.java | 2 +-
.../src/main/java/org/apache/nifi/processors/standard/TailFile.java | 2 +-
.../java/org/apache/nifi/processors/standard/merge/RecordBin.java | 2 +-
.../java/org/apache/nifi/processors/attributes/UpdateAttribute.java | 2 +-
25 files changed, 28 insertions(+), 28 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java
index 0c0420dc445..d8844cb7d31 100644
---
a/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java
+++
b/nifi-extension-bundles/nifi-amqp-bundle/nifi-amqp-processors/src/main/java/org/apache/nifi/amqp/processors/ConsumeAMQP.java
@@ -124,7 +124,7 @@ public class ConsumeAMQP extends
AbstractAMQPProcessor<AMQPConsumer> {
.build();
public static final PropertyDescriptor HEADER_KEY_PREFIX = new
PropertyDescriptor.Builder()
.name("Header Key Prefix")
- .description("Text to be prefixed to header keys as the are added to
the FlowFile attributes. Processor will append '.' to the value of this
property")
+ .description("Text to be prefixed to header keys as they are added to
the FlowFile attributes. Processor will append '.' to the value of this
property")
.defaultValue(DEFAULT_HEADERS_KEY_PREFIX)
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
.dependsOn(HEADER_FORMAT, OutputHeaderFormat.ATTRIBUTES)
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AbstractAwsProcessor.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AbstractAwsProcessor.java
index 950a4f4c8ad..a0dd073dd13 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AbstractAwsProcessor.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AbstractAwsProcessor.java
@@ -246,7 +246,7 @@ public abstract class AbstractAwsProcessor<C extends
AwsClient, B extends AwsCli
results.add(new ConfigVerificationResult.Builder()
.outcome(Outcome.FAILED)
.verificationStepName("Create Client")
- .explanation("Failed to crete AWS Client: " +
e.getMessage())
+ .explanation("Failed to create AWS Client: " +
e.getMessage())
.build());
}
diff --git
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-reporting-task/src/main/java/org/apache/nifi/reporting/azure/loganalytics/AzureLogAnalyticsProvenanceReportingTask.java
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-reporting-task/src/main/java/org/apache/nifi/reporting/azure/loganalytics/AzureLogAnalyticsProvenanceReportingTask.java
index 6eaddcf8216..9ba6eeddcea 100644
---
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-reporting-task/src/main/java/org/apache/nifi/reporting/azure/loganalytics/AzureLogAnalyticsProvenanceReportingTask.java
+++
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-reporting-task/src/main/java/org/apache/nifi/reporting/azure/loganalytics/AzureLogAnalyticsProvenanceReportingTask.java
@@ -53,7 +53,7 @@ import java.util.Map;
import java.util.UUID;
@Tags({ "azure", "provenance", "reporting", "log analytics" })
-@CapabilityDescription("Publishes Provenance events to to a Azure Log
Analytics workspace.")
+@CapabilityDescription("Publishes Provenance events to a Azure Log Analytics
workspace.")
public class AzureLogAnalyticsProvenanceReportingTask extends
AbstractAzureLogAnalyticsReportingTask {
protected static final String LAST_EVENT_ID_KEY = "last_event_id";
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
index 7c8934eb05c..14a920292ea 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
@@ -175,7 +175,7 @@ public class ConsumeElasticsearch extends
SearchElasticsearch {
.name("Additional Filters")
.description("One or more query filters in JSON syntax, not Lucene
syntax. " +
"Ex: [{\"match\":{\"somefield\":\"somevalue\"}},
{\"match\":{\"anotherfield\":\"anothervalue\"}}]. " +
- "These filters wil be used as part of a Bool query's
filter.")
+ "These filters will be used as part of a Bool query's
filter.")
.addValidator(JsonValidator.INSTANCE)
.required(false)
.build();
diff --git
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIP.java
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIP.java
index a1e736245e8..0ab2d89629a 100644
---
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIP.java
+++
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIP.java
@@ -50,7 +50,7 @@ import java.util.concurrent.locks.Lock;
@InputRequirement(Requirement.INPUT_REQUIRED)
@CapabilityDescription("Looks up geolocation information for an IP address and
adds the geo information to FlowFile attributes. The "
+ "geo data is provided as a MaxMind database. The attribute that
contains the IP address to lookup is provided by the "
- + "'IP Address Attribute' property. If the name of the attribute
provided is 'X', then the the attributes added by enrichment "
+ + "'IP Address Attribute' property. If the name of the attribute
provided is 'X', then the attributes added by enrichment "
+ "will take the form X.geo.<fieldName>")
@WritesAttributes({
@WritesAttribute(attribute = "X.geo.lookup.micros", description = "The
number of microseconds that the geo lookup took"),
diff --git
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/ISPEnrichIP.java
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/ISPEnrichIP.java
index c32062cbc6d..8d3b38828cd 100644
---
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/ISPEnrichIP.java
+++
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/ISPEnrichIP.java
@@ -47,7 +47,7 @@ import java.util.concurrent.TimeUnit;
@CapabilityDescription("Looks up ISP information for an IP address and adds
the information to FlowFile attributes. The "
+ "ISP data is provided as a MaxMind ISP database. (Note that this is
NOT the same as the GeoLite database utilized " +
"by some geo enrichment tools). The attribute that contains the IP
address to lookup is provided by the " +
- "'IP Address Attribute' property. If the name of the attribute
provided is 'X', then the the attributes added by" +
+ "'IP Address Attribute' property. If the name of the attribute
provided is 'X', then the attributes added by" +
" enrichment will take the form X.isp.<fieldName>")
@WritesAttributes({
@WritesAttribute(attribute = "X.isp.lookup.micros", description = "The
number of microseconds that the geo lookup took"),
diff --git
a/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/PutFileTransfer.java
b/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/PutFileTransfer.java
index f0135f5d2e0..a0d5baaebdc 100644
---
a/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/PutFileTransfer.java
+++
b/nifi-extension-bundles/nifi-extension-utils/nifi-file-transfer/src/main/java/org/apache/nifi/processor/util/file/transfer/PutFileTransfer.java
@@ -246,7 +246,7 @@ public abstract class PutFileTransfer<T extends
FileTransfer> extends AbstractPr
destinationRelationship = REL_SUCCESS;
transferFile = false;
penalizeFile = false;
- logger.info("Resolving conflict for {} by not transferring
file and and still considering the process a success.", flowFile);
+ logger.info("Resolving conflict for {} by not transferring
file and still considering the process a success.", flowFile);
break;
case FileTransfer.CONFLICT_RESOLUTION_FAIL:
destinationRelationship = REL_FAILURE;
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/ListHDFS.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/ListHDFS.java
index 434990cc67a..73877dc567c 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/ListHDFS.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/ListHDFS.java
@@ -84,7 +84,7 @@ import static
org.apache.nifi.processors.hadoop.util.FilterMode.FILTER_DIRECTORI
@WritesAttribute(attribute = "hdfs.group", description = "The group
that owns the file in HDFS"),
@WritesAttribute(attribute = "hdfs.lastModified", description = "The
timestamp of when the file in HDFS was last modified, as milliseconds since
midnight Jan 1, 1970 UTC"),
@WritesAttribute(attribute = "hdfs.length", description = "The number
of bytes in the file in HDFS"),
- @WritesAttribute(attribute = "hdfs.replication", description = "The
number of HDFS replicas for hte file"),
+ @WritesAttribute(attribute = "hdfs.replication", description = "The
number of HDFS replicas for the file"),
@WritesAttribute(attribute = "hdfs.permissions", description = "The
permissions for the file in HDFS. This is formatted as 3 characters for the
owner, "
+ "3 for the group, and 3 for other users. For example
rw-rw-r--")
})
diff --git
a/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/AbstractJMSProcessor.java
b/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/AbstractJMSProcessor.java
index 6e343a5c452..7b1df573079 100644
---
a/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/AbstractJMSProcessor.java
+++
b/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/AbstractJMSProcessor.java
@@ -122,7 +122,7 @@ public abstract class AbstractJMSProcessor<T extends
JMSWorker> extends Abstract
static final PropertyDescriptor CF_SERVICE = new
PropertyDescriptor.Builder()
.name("Connection Factory Service")
.description("The Controller Service that is used to obtain
Connection Factory. Alternatively, the 'JNDI *' or the 'JMS *' properties " +
- "can also be be used to configure the Connection Factory.")
+ "can also be used to configure the Connection Factory.")
.required(false)
.identifiesControllerService(JMSConnectionFactoryProviderDefinition.class)
.build();
diff --git
a/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
b/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
index 2b11e209089..9a1240642d4 100644
---
a/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
+++
b/nifi-extension-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java
@@ -103,12 +103,12 @@ public class ConsumeJMS extends
AbstractJMSProcessor<JMSConsumer> {
static final AllowableValue AUTO_ACK = new
AllowableValue(String.valueOf(Session.AUTO_ACKNOWLEDGE),
"AUTO_ACKNOWLEDGE (" + Session.AUTO_ACKNOWLEDGE + ")",
- "Automatically acknowledges a client's receipt of a message,
regardless if NiFi session has been commited. "
- + "Can result in data loss in the event where NiFi
abruptly stopped before session was commited.");
+ "Automatically acknowledges a client's receipt of a message,
regardless if NiFi session has been committed. "
+ + "Can result in data loss in the event where NiFi
abruptly stopped before session was committed.");
static final AllowableValue CLIENT_ACK = new
AllowableValue(String.valueOf(Session.CLIENT_ACKNOWLEDGE),
"CLIENT_ACKNOWLEDGE (" + Session.CLIENT_ACKNOWLEDGE + ")",
- "(DEFAULT) Manually acknowledges a client's receipt of a message
after NiFi Session was commited, thus ensuring no data loss");
+ "(DEFAULT) Manually acknowledges a client's receipt of a message
after NiFi Session was committed, thus ensuring no data loss");
static final AllowableValue DUPS_OK = new
AllowableValue(String.valueOf(Session.DUPS_OK_ACKNOWLEDGE),
"DUPS_OK_ACKNOWLEDGE (" + Session.DUPS_OK_ACKNOWLEDGE + ")",
diff --git
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
index ba08b5c69c6..b972e076f13 100644
---
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
+++
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/Kafka3ConnectionService.java
@@ -108,7 +108,7 @@ public class Kafka3ConnectionService extends
AbstractControllerService implement
.displayName("Transaction Isolation Level")
.description("""
Specifies how the service should handle transaction
isolation levels when communicating with Kafka.
- The uncommited option means that messages will be received
as soon as they are written to Kafka but will be pulled, even if the producer
cancels the transactions.
+ The uncommitted option means that messages will be
received as soon as they are written to Kafka but will be pulled, even if the
producer cancels the transactions.
The committed option configures the service to not receive
any messages for which the producer's transaction was canceled, but this can
result in some latency since the
consumer must wait for the producer to finish its entire
transaction instead of pulling as the messages become available.
Corresponds to Kafka isolation.level property.
diff --git
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/producer/transaction/KafkaTransactionalProducerWrapper.java
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/producer/transaction/KafkaTransactionalProducerWrapper.java
index 1e3ded07dac..80b96ae3c3d 100644
---
a/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/producer/transaction/KafkaTransactionalProducerWrapper.java
+++
b/nifi-extension-bundles/nifi-kafka-bundle/nifi-kafka-service-shared/src/main/java/org/apache/nifi/kafka/service/producer/transaction/KafkaTransactionalProducerWrapper.java
@@ -56,7 +56,7 @@ public class KafkaTransactionalProducerWrapper extends
KafkaProducerWrapper {
// If we logged any warning that we timed out and will
retry, we should log a notification
// that we were successful this time. Otherwise, don't
spam the logs.
if (failure) {
- logger.info("Successfully commited producer
transaction after {} retries", i);
+ logger.info("Successfully committed producer
transaction after {} retries", i);
}
break;
} catch (final TimeoutException te) {
diff --git
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
index d3904189fe2..7a625ba21ba 100644
---
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
+++
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
@@ -98,8 +98,8 @@ public class ExtractMediaMetadata extends AbstractProcessor {
static final PropertyDescriptor METADATA_KEY_PREFIX = new
PropertyDescriptor.Builder()
.name("Metadata Key Prefix")
- .description("Text to be prefixed to metadata keys as the are
added to the FlowFile attributes. It is"
- + " recommended to end with with a separator character
like '.' or '-', this is not automatically "
+ .description("Text to be prefixed to metadata keys as they are
added to the FlowFile attributes. It is"
+ + " recommended to end with a separator character like '.'
or '-', this is not automatically "
+ " added by the processor.")
.required(false)
.addValidator(StandardValidators.ATTRIBUTE_KEY_VALIDATOR)
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
index 8647c67e8dc..ef5152fcf56 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
@@ -180,7 +180,7 @@ public class FetchGridFS extends AbstractGridFSProcessor
implements QueryHelper
session.transfer(input, REL_ORIGINAL);
}
} catch (Exception ex) {
- getLogger().error("An error occurred wile trying to run the
query.", ex);
+ getLogger().error("An error occurred while trying to run the
query.", ex);
if (input != null &&
operatingMode.equals(MODE_ONE_COMMIT.getValue())) {
session.transfer(input, REL_FAILURE);
} else if (input != null &&
operatingMode.equals(MODE_MANY_COMMITS.getValue())) {
diff --git
a/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/GetSplunk.java
b/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/GetSplunk.java
index 5c64bd8c31b..b2fb7b27cfd 100644
---
a/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/GetSplunk.java
+++
b/nifi-extension-bundles/nifi-splunk-bundle/nifi-splunk-processors/src/main/java/org/apache/nifi/processors/splunk/GetSplunk.java
@@ -163,7 +163,7 @@ public class GetSplunk extends AbstractProcessor {
public static final AllowableValue MANAGED_CURRENT_VALUE = new
AllowableValue("Managed from Current", "Managed from Current",
"The processor will manage the date ranges of the query starting
from the current time.");
public static final AllowableValue PROVIDED_VALUE = new
AllowableValue("Provided", "Provided",
- "The the time range provided through the Earliest Time and Latest
Time properties will be used.");
+ "The time range provided through the Earliest Time and Latest Time
properties will be used.");
public static final PropertyDescriptor TIME_RANGE_STRATEGY = new
PropertyDescriptor.Builder()
.name("Time Range Strategy")
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
index ea6bdea6f43..c7c9ae66acc 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
@@ -100,7 +100,7 @@ public class AttributesToJSON extends AbstractProcessor {
.name("Attributes List")
.description("Comma separated list of attributes to be included in
the resulting JSON. If this value " +
"is left empty then all existing Attributes will be
included. This list of attributes is " +
- "case sensitive. If an attribute specified in the list is
not found it will be be emitted " +
+ "case sensitive. If an attribute specified in the list is
not found it will be emitted " +
"to the resulting JSON with an empty string or NULL
value.")
.required(false)
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java
index 29b6845b7bb..6b8b0e99312 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/DeleteSFTP.java
@@ -119,7 +119,7 @@ public class DeleteSFTP extends AbstractProcessor {
public static final PropertyDescriptor DIRECTORY_PATH = new
PropertyDescriptor.Builder()
.name("Directory Path")
- .description("The path to the the actual directory to delete or
the path to the directory the file to delete is located in.")
+ .description("The path to the actual directory to delete or the
path to the directory the file to delete is located in.")
.required(true)
.defaultValue("${" + CoreAttributes.PATH.key() + "}")
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractText.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractText.java
index e02a90e3f21..1e5273b4278 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractText.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractText.java
@@ -166,7 +166,7 @@ public class ExtractText extends AbstractProcessor {
public static final PropertyDescriptor MULTILINE = new
PropertyDescriptor.Builder()
.name("Enable Multiline Mode")
.description("Indicates that '^' and '$' should match just after
and just before a line terminator or end of sequence, instead of "
- + "only the beginning or end of the entire input. Can
also be specified via the embeded flag (?m).")
+ + "only the beginning or end of the entire input. Can
also be specified via the embedded flag (?m).")
.required(true)
.allowableValues("true", "false")
.defaultValue("false")
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
index 286508195f3..f4ca1264ee0 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ListenHTTP.java
@@ -210,7 +210,7 @@ public class ListenHTTP extends
AbstractSessionFactoryProcessor implements Liste
public static final PropertyDescriptor AUTHORIZED_DN_PATTERN = new
PropertyDescriptor.Builder()
.name("Authorized Subject DN Pattern")
.description("A Regular Expression to apply against the Subject's
Distinguished Name of incoming connections. If the Pattern does not match the
Subject DN, " +
- "the the processor will respond with a status of HTTP 403
Forbidden.")
+ "the processor will respond with a status of HTTP 403
Forbidden.")
.required(true)
.defaultValue(MATCH_ALL)
.addValidator(StandardValidators.REGULAR_EXPRESSION_VALIDATOR)
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupAttribute.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupAttribute.java
index f19eadd6086..9bc692dbe77 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupAttribute.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/LookupAttribute.java
@@ -63,7 +63,7 @@ import java.util.stream.Collectors;
@DynamicProperty(name = "The name of the attribute to add to the FlowFile",
value = "The name of the key or property to retrieve from the lookup
service",
expressionLanguageScope = ExpressionLanguageScope.FLOWFILE_ATTRIBUTES,
- description = "Adds a FlowFile attribute specified by the dynamic
property's key with the value found in the lookup service using the the dynamic
property's value")
+ description = "Adds a FlowFile attribute specified by the dynamic
property's key with the value found in the lookup service using the dynamic
property's value")
public class LookupAttribute extends AbstractProcessor {
public static final PropertyDescriptor LOOKUP_SERVICE =
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
index f0b92aa0681..b70ace77a48 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryRecord.java
@@ -153,7 +153,7 @@ import static
org.apache.nifi.util.db.JdbcProperties.DEFAULT_SCALE;
"""
)
@UseCase(
- description = "Keep only specific fields in a a Record, where the names of
the fields to keep are known",
+ description = "Keep only specific fields in a Record, where the names of
the fields to keep are known",
keywords = {"keep", "filter", "retain", "select", "include", "record",
"fields", "sql"},
configuration = """
"Record Reader" should be set to a Record Reader that is appropriate
for your data.
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteText.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteText.java
index 50b9f53c30d..02ac7feea6c 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteText.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteText.java
@@ -145,7 +145,7 @@ public class RouteText extends AbstractProcessor {
public static final AllowableValue CONTAINS_REGULAR_EXPRESSION = new
AllowableValue(containsRegularExpressionValue, containsRegularExpressionValue,
"Match lines based on whether the line contains some text that matches
the Regular Expression that is provided as the Property value");
public static final AllowableValue SATISFIES_EXPRESSION = new
AllowableValue(satisfiesExpression, satisfiesExpression,
- "Match lines based on whether or not the the text satisfies the given
Expression Language expression. I.e., the line will match if the property
value, evaluated as "
+ "Match lines based on whether or not the text satisfies the given
Expression Language expression. I.e., the line will match if the property
value, evaluated as "
+ "an Expression, returns true. The expression is able to
reference FlowFile Attributes, as well as the variables 'line' (which is the
text of the line to evaluate) and "
+ "'lineNo' (which is the line number being evaluated. This will
be 1 for the first line, 2 for the second and so on).");
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java
index 3b4fc42e0e1..baacc5288d8 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TailFile.java
@@ -128,7 +128,7 @@ public class TailFile extends AbstractProcessor {
static final AllowableValue START_CURRENT_FILE = new
AllowableValue("Beginning of File", "Beginning of File",
"Start with the beginning of the File to Tail. Do not ingest any
data that has already been rolled over");
static final AllowableValue START_CURRENT_TIME = new
AllowableValue("Current Time", "Current Time",
- "Start with the data at the end of the File to Tail. Do not ingest
any data thas has already been rolled over or any "
+ "Start with the data at the end of the File to Tail. Do not ingest
any data that has already been rolled over or any "
+ "data in the File to Tail that has already been written.");
static final PropertyDescriptor BASE_DIRECTORY = new Builder()
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/merge/RecordBin.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/merge/RecordBin.java
index 893d6b8174d..d4c5e167e66 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/merge/RecordBin.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/merge/RecordBin.java
@@ -378,7 +378,7 @@ public class RecordBin {
Integer expectedFragmentCount = thresholds.getFragmentCount();
if (expectedFragmentCount != flowFiles.size()) {
logger.error("Could not merge bin with {} FlowFiles
because the '{}' attribute had a value of '{}' but only {} of {} FlowFiles were
encountered before this bin was evicted "
- + "(due to to Max Bin Age being reached or
due to the Maximum Number of Bins being exceeded).",
+ + "(due to Max Bin Age being reached or
due to the Maximum Number of Bins being exceeded).",
flowFiles.size(), countAttr.get(),
expectedFragmentCount, flowFiles.size(), expectedFragmentCount);
fail();
return;
diff --git
a/nifi-extension-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java
b/nifi-extension-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java
index 0a3a781e149..fd32d0f46d2 100644
---
a/nifi-extension-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java
+++
b/nifi-extension-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java
@@ -173,7 +173,7 @@ public class UpdateAttribute extends AbstractProcessor
implements Searchable {
.subject(subject)
.input(input)
.valid(false)
- .explanation("Expected property to to return type
" + AttributeExpression.ResultType.STRING +
+ .explanation("Expected property to return type " +
AttributeExpression.ResultType.STRING +
" but expression returns type " +
resultType)
.build();
}
