Repository: nifi Updated Branches: refs/heads/master f15707637 -> 3b408f560
http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/test/java/org/apache/nifi/hbase/TestPutHBaseCell.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/test/java/org/apache/nifi/hbase/TestPutHBaseCell.java b/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/test/java/org/apache/nifi/hbase/TestPutHBaseCell.java index 2d9068f..ee6a53f 100644 --- a/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/test/java/org/apache/nifi/hbase/TestPutHBaseCell.java +++ b/nifi-nar-bundles/nifi-hbase-bundle/nifi-hbase-processors/src/test/java/org/apache/nifi/hbase/TestPutHBaseCell.java @@ -83,7 +83,7 @@ public class TestPutHBaseCell { final MockHBaseClientService hBaseClient = getHBaseClientService(runner); final String content = "some content"; - final Map<String, String> attributes = getAtrributeMapWithEL(tableName, row, columnFamily, columnQualifier); + final Map<String, String> attributes = getAttributeMapWithEL(tableName, row, columnFamily, columnQualifier); runner.enqueue(content.getBytes("UTF-8"), attributes); runner.run(); @@ -144,7 +144,7 @@ public class TestPutHBaseCell { // this will go to success final String content2 = "some content2"; - final Map<String, String> attributes = getAtrributeMapWithEL("table", "row", "cf", "cq"); + final Map<String, String> attributes = getAttributeMapWithEL("table", "row", "cf", "cq"); runner.enqueue(content2.getBytes("UTF-8"), attributes); runner.run(); @@ -167,11 +167,11 @@ public class TestPutHBaseCell { final MockHBaseClientService hBaseClient = getHBaseClientService(runner); final String content1 = "some content1"; - final Map<String, String> attributes1 = getAtrributeMapWithEL(tableName, row1, columnFamily, columnQualifier); + final Map<String, String> attributes1 = getAttributeMapWithEL(tableName, row1, columnFamily, columnQualifier); runner.enqueue(content1.getBytes("UTF-8"), attributes1); final String content2 = "some content1"; - final Map<String, String> attributes2 = getAtrributeMapWithEL(tableName, row2, columnFamily, columnQualifier); + final Map<String, String> attributes2 = getAttributeMapWithEL(tableName, row2, columnFamily, columnQualifier); runner.enqueue(content2.getBytes("UTF-8"), attributes2); runner.run(); @@ -205,11 +205,11 @@ public class TestPutHBaseCell { hBaseClient.setThrowException(true); final String content1 = "some content1"; - final Map<String, String> attributes1 = getAtrributeMapWithEL(tableName, row1, columnFamily, columnQualifier); + final Map<String, String> attributes1 = getAttributeMapWithEL(tableName, row1, columnFamily, columnQualifier); runner.enqueue(content1.getBytes("UTF-8"), attributes1); final String content2 = "some content1"; - final Map<String, String> attributes2 = getAtrributeMapWithEL(tableName, row2, columnFamily, columnQualifier); + final Map<String, String> attributes2 = getAttributeMapWithEL(tableName, row2, columnFamily, columnQualifier); runner.enqueue(content2.getBytes("UTF-8"), attributes2); runner.run(); @@ -230,7 +230,7 @@ public class TestPutHBaseCell { final MockHBaseClientService hBaseClient = getHBaseClientService(runner); final String content1 = "some content1"; - final Map<String, String> attributes1 = getAtrributeMapWithEL(tableName, row, columnFamily, columnQualifier); + final Map<String, String> attributes1 = getAttributeMapWithEL(tableName, row, columnFamily, columnQualifier); runner.enqueue(content1.getBytes("UTF-8"), attributes1); final String content2 = "some content1"; @@ -299,7 +299,7 @@ public class TestPutHBaseCell { assertEquals(1, runner.getProvenanceEvents().size()); } - private Map<String, String> getAtrributeMapWithEL(String tableName, String row, String columnFamily, String columnQualifier) { + private Map<String, String> getAttributeMapWithEL(String tableName, String row, String columnFamily, String columnQualifier) { final Map<String,String> attributes1 = new HashMap<>(); attributes1.put("hbase.tableName", tableName); attributes1.put("hbase.row", row); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java index 27a7f01..8300312 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/main/java/org/apache/nifi/processors/hive/PutHiveQL.java @@ -64,9 +64,9 @@ import java.util.regex.Pattern; + "with the naming convention hiveql.args.N.type and hiveql.args.N.value, where N is a positive integer. The hiveql.args.N.type is expected to be " + "a number indicating the JDBC Type. The content of the FlowFile is expected to be in UTF-8 format.") @ReadsAttributes({ - @ReadsAttribute(attribute = "hiveql.args.N.type", description = "Incoming FlowFiles are expected to be parameterized HiveQL statements. The type of each Parameter is specified as an integer " + @ReadsAttribute(attribute = "hiveql.args.N.type", description = "Incoming FlowFiles are expected to be parametrized HiveQL statements. The type of each Parameter is specified as an integer " + "that represents the JDBC Type of the parameter."), - @ReadsAttribute(attribute = "hiveql.args.N.value", description = "Incoming FlowFiles are expected to be parameterized HiveQL statements. The value of the Parameters are specified as " + @ReadsAttribute(attribute = "hiveql.args.N.value", description = "Incoming FlowFiles are expected to be parametrized HiveQL statements. The value of the Parameters are specified as " + "hiveql.args.1.value, hiveql.args.2.value, hiveql.args.3.value, and so on. The type of the hiveql.args.1.value Parameter is specified by the hiveql.args.1.type attribute.") }) public class PutHiveQL extends AbstractHiveQLProcessor { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java index 8142e3f..6ce21e9 100644 --- a/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java +++ b/nifi-nar-bundles/nifi-hive-bundle/nifi-hive-processors/src/test/java/org/apache/nifi/processors/hive/TestSelectHiveQL.java @@ -165,7 +165,7 @@ public class TestSelectHiveQL { stmt.execute("create table TEST_NO_ROWS (id integer)"); runner.setIncomingConnection(false); - // Try a valid SQL statment that will generate an error (val1 does not exist, e.g.) + // Try a valid SQL statement that will generate an error (val1 does not exist, e.g.) runner.setProperty(SelectHiveQL.HIVEQL_SELECT_QUERY, "SELECT val1 FROM TEST_NO_ROWS"); runner.run(); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-html-bundle/nifi-html-processors/src/main/java/org/apache/nifi/AbstractHTMLProcessor.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-html-bundle/nifi-html-processors/src/main/java/org/apache/nifi/AbstractHTMLProcessor.java b/nifi-nar-bundles/nifi-html-bundle/nifi-html-processors/src/main/java/org/apache/nifi/AbstractHTMLProcessor.java index 20dca29..127f0d8 100644 --- a/nifi-nar-bundles/nifi-html-bundle/nifi-html-processors/src/main/java/org/apache/nifi/AbstractHTMLProcessor.java +++ b/nifi-nar-bundles/nifi-html-bundle/nifi-html-processors/src/main/java/org/apache/nifi/AbstractHTMLProcessor.java @@ -102,7 +102,7 @@ public abstract class AbstractHTMLProcessor extends AbstractProcessor { public static final Relationship REL_NOT_FOUND = new Relationship.Builder() .name("element not found") .description("Element could not be found in the HTML document. The original HTML input will remain " + - "in the flowfile content unchanged. Relationship '" + REL_ORIGINAL + "' will not be invoked " + + "in the FlowFile content unchanged. Relationship '" + REL_ORIGINAL + "' will not be invoked " + "in this scenario.") .build(); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/main/java/org/apache/nifi/processors/ignite/cache/PutIgniteCache.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/main/java/org/apache/nifi/processors/ignite/cache/PutIgniteCache.java b/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/main/java/org/apache/nifi/processors/ignite/cache/PutIgniteCache.java index c61649f..316ed8f 100644 --- a/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/main/java/org/apache/nifi/processors/ignite/cache/PutIgniteCache.java +++ b/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/main/java/org/apache/nifi/processors/ignite/cache/PutIgniteCache.java @@ -59,7 +59,7 @@ import org.apache.nifi.stream.io.StreamUtils; @CapabilityDescription("Stream the contents of a FlowFile to Ignite Cache using DataStreamer. " + "The processor uses the value of FlowFile attribute (Ignite cache entry key) as the " + "cache key and the byte array of the FlowFile as the value of the cache entry value. Both the string key and a " + - " non-empty byte array value are required otherwise the FlowFile is transfered to the failure relation. " + + " non-empty byte array value are required otherwise the FlowFile is transferred to the failure relation. " + "Note - The Ignite Kernel periodically outputs node performance statistics to the logs. This message " + " can be turned off by setting the log level for logger 'org.apache.ignite' to WARN in the logback.xml configuration file.") @WritesAttributes({ @@ -208,7 +208,7 @@ public class PutIgniteCache extends AbstractIgniteCacheProcessor { * Initialize ignite cache */ @OnScheduled - public final void initilizeIgniteDataStreamer(ProcessContext context) throws ProcessException { + public final void initializeIgniteDataStreamer(ProcessContext context) throws ProcessException { super.initializeIgniteCache(context); if ( getIgniteDataStreamer() != null ) { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/test/java/org/apache/nifi/processors/ignite/cache/TestPutIgniteCache.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/test/java/org/apache/nifi/processors/ignite/cache/TestPutIgniteCache.java b/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/test/java/org/apache/nifi/processors/ignite/cache/TestPutIgniteCache.java index eebb237..5639795 100644 --- a/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/test/java/org/apache/nifi/processors/ignite/cache/TestPutIgniteCache.java +++ b/nifi-nar-bundles/nifi-ignite-bundle/nifi-ignite-processors/src/test/java/org/apache/nifi/processors/ignite/cache/TestPutIgniteCache.java @@ -92,8 +92,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_SUCCESS, 1); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(1, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(1, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(0, failureFlowFiles.size()); @@ -123,8 +123,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_SUCCESS, 1); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(1, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(1, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(0, failureFlowFiles.size()); @@ -156,8 +156,8 @@ public class TestPutIgniteCache { runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_SUCCESS, 2); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(2, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(2, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(0, failureFlowFiles.size()); @@ -201,8 +201,8 @@ public class TestPutIgniteCache { runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_SUCCESS, 2); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(2, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(2, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(0, failureFlowFiles.size()); @@ -245,8 +245,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_FAILURE, 1); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(0, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(0, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(1, failureFlowFiles.size()); @@ -277,8 +277,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_FAILURE, 1); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(0, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(0, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(1, failureFlowFiles.size()); @@ -310,8 +310,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_SUCCESS, 2); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(2, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(2, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(0, failureFlowFiles.size()); @@ -355,8 +355,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_FAILURE, 2); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(0, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(0, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(2, failureFlowFiles.size()); @@ -400,8 +400,8 @@ public class TestPutIgniteCache { runner.enqueue("test2".getBytes(),properties2); runner.run(1, false, true); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(1, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(1, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(1, failureFlowFiles.size()); @@ -445,8 +445,8 @@ public class TestPutIgniteCache { runner.enqueue("test2".getBytes()); runner.run(1, false, true); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(1, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(1, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(1, failureFlowFiles.size()); @@ -492,8 +492,8 @@ public class TestPutIgniteCache { runner.run(1, false, true); runner.assertAllFlowFilesTransferred(PutIgniteCache.REL_FAILURE, 2); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(0, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(0, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(2, failureFlowFiles.size()); @@ -538,8 +538,8 @@ public class TestPutIgniteCache { runner.enqueue("".getBytes(),properties2); runner.run(1, false, true); - List<MockFlowFile> sucessfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); - assertEquals(1, sucessfulFlowFiles.size()); + List<MockFlowFile> successfulFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_SUCCESS); + assertEquals(1, successfulFlowFiles.size()); List<MockFlowFile> failureFlowFiles = runner.getFlowFilesForRelationship(PutIgniteCache.REL_FAILURE); assertEquals(2, failureFlowFiles.size()); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-cf-service/src/main/java/org/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-cf-service/src/main/java/org/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-cf-service/src/main/java/org/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java index c4608be..32ff78c 100644 --- a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-cf-service/src/main/java/org/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java +++ b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-cf-service/src/main/java/org/apache/nifi/jms/cf/JMSConnectionFactoryProvider.java @@ -117,7 +117,7 @@ public class JMSConnectionFactoryProvider extends AbstractControllerService impl if (!this.configured) { if (logger.isInfoEnabled()) { logger.info("Configuring " + this.getClass().getSimpleName() + " for '" - + context.getProperty(CONNECTION_FACTORY_IMPL).evaluateAttributeExpressions().getValue() + "' to be conected to '" + + context.getProperty(CONNECTION_FACTORY_IMPL).evaluateAttributeExpressions().getValue() + "' to be connected to '" + BROKER_URI + "'"); } // will load user provided libraries/resources on the classpath http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java index aea6c9c..b76a1a7 100644 --- a/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java +++ b/nifi-nar-bundles/nifi-jms-bundle/nifi-jms-processors/src/main/java/org/apache/nifi/jms/processors/ConsumeJMS.java @@ -118,7 +118,7 @@ public class ConsumeJMS extends AbstractJMSProcessor<JMSConsumer> { /** * Copies JMS attributes (i.e., headers and properties) as FF attributes. * Given that FF attributes mandate that values are of type String, the - * copied values of JMS attributes will be stringified via + * copied values of JMS attributes will be "stringified" via * String.valueOf(attribute). */ private FlowFile updateFlowFileAttributesWithJMSAttributes(Map<String, Object> jmsAttributes, FlowFile flowFile, http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java index 41c8cc6..b061fcc 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka_0_10.java @@ -81,7 +81,7 @@ public class ConsumeKafka_0_10 extends AbstractProcessor { static final PropertyDescriptor TOPICS = new PropertyDescriptor.Builder() .name("topic") .displayName("Topic Name(s)") - .description("The name of the Kafka Topic(s) to pull from. More than one can be supplied if comma seperated.") + .description("The name of the Kafka Topic(s) to pull from. More than one can be supplied if comma separated.") .required(true) .addValidator(StandardValidators.NON_BLANK_VALIDATOR) .expressionLanguageSupported(true) http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java index c611fa2..97ebfc6 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-10-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumerLease.java @@ -108,7 +108,7 @@ public abstract class ConsumerLease implements Closeable, ConsumerRebalanceListe @Override public void onPartitionsRevoked(final Collection<TopicPartition> partitions) { logger.debug("Rebalance Alert: Paritions '{}' revoked for lease '{}' with consumer '{}'", new Object[]{partitions, this, kafkaConsumer}); - //force a commit here. Can reuse the session and consumer after this but must commit now to avoid duplicates if kafka reassigns parittion + //force a commit here. Can reuse the session and consumer after this but must commit now to avoid duplicates if kafka reassigns partition commit(); } http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java index 7660305..eb833df 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/GetKafka.java @@ -80,7 +80,7 @@ import kafka.message.MessageAndMetadata; @DynamicProperty(name = "The name of a Kafka configuration property.", value = "The value of a given Kafka configuration property.", description = "These properties will be added on the Kafka configuration after loading any provided configuration properties." + " In the event a dynamic property represents a property that was already set as part of the static properties, its value wil be" - + " overriden with warning message describing the override." + + " overridden with warning message describing the override." + " For the list of available Kafka properties please refer to: http://kafka.apache.org/documentation.html#configuration.";) public class GetKafka extends AbstractProcessor { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java index 8ddea61..2fbc9ae 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/KafkaUtils.java @@ -28,7 +28,7 @@ import kafka.utils.ZKStringSerializer; import scala.collection.JavaConversions; /** - * Utility class to support interruction with Kafka internals. + * Utility class to support interaction with Kafka internals. * */ class KafkaUtils { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java index 4dc8d18..008c731 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/main/java/org/apache/nifi/processors/kafka/PutKafka.java @@ -272,9 +272,9 @@ public class PutKafka extends AbstractKafkaProcessor<KafkaPublisher> { * Will rendezvous with Kafka if {@link ProcessSession} contains {@link FlowFile} * producing a result {@link FlowFile}. * <br> - * The result {@link FlowFile} that is successful is then transfered to {@link #REL_SUCCESS} + * The result {@link FlowFile} that is successful is then transferred to {@link #REL_SUCCESS} * <br> - * The result {@link FlowFile} that is failed is then transfered to {@link #REL_FAILURE} + * The result {@link FlowFile} that is failed is then transferred to {@link #REL_FAILURE} * */ @Override http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java index effc8e7..09098ff 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/java/org/apache/nifi/processors/kafka/GetKafkaIntegrationTests.java @@ -41,7 +41,7 @@ public class GetKafkaIntegrationTests { private static EmbeddedKafkaProducerHelper producerHelper; @BeforeClass - public static void bforeClass(){ + public static void beforeClass(){ kafkaLocal = new EmbeddedKafka(); kafkaLocal.start(); producerHelper = new EmbeddedKafkaProducerHelper(kafkaLocal); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties index 9c44acc..ec4c25a 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-8-processors/src/test/resources/server.properties @@ -54,7 +54,7 @@ socket.request.max.bytes=104857600 ############################# Log Basics ############################# -# A comma seperated list of directories under which to store log files +# A comma separated list of directories under which to store log files log.dirs=target/kafka-tmp/kafka-logs # The default number of log partitions per topic. More partitions allow greater http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java index c311e2a..5792e64 100644 --- a/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java +++ b/nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-0-9-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/ConsumeKafka.java @@ -81,7 +81,7 @@ public class ConsumeKafka extends AbstractProcessor { static final PropertyDescriptor TOPICS = new PropertyDescriptor.Builder() .name("topic") .displayName("Topic Name(s)") - .description("The name of the Kafka Topic(s) to pull from. More than one can be supplied if comma seperated.") + .description("The name of the Kafka Topic(s) to pull from. More than one can be supplied if comma separated.") .required(true) .addValidator(StandardValidators.NON_BLANK_VALIDATOR) .expressionLanguageSupported(true) http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/test/java/org/apache/nifi/processors/lumberjack/handler/TestLumberjackFrameHandler.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/test/java/org/apache/nifi/processors/lumberjack/handler/TestLumberjackFrameHandler.java b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/test/java/org/apache/nifi/processors/lumberjack/handler/TestLumberjackFrameHandler.java index aea5961..4a73b30 100644 --- a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/test/java/org/apache/nifi/processors/lumberjack/handler/TestLumberjackFrameHandler.java +++ b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/test/java/org/apache/nifi/processors/lumberjack/handler/TestLumberjackFrameHandler.java @@ -92,7 +92,7 @@ public class TestLumberjackFrameHandler { 0x00, 0x00, 0x00, 0x02, // Number of pairs 0x00, 0x00, 0x00, 0x04, // Length of first pair key ('line') 0x6C, 0x69, 0x6E, 0x65, // 'line' - 0x00, 0x00, 0x00, 0x0C, // Lenght of 'test-content' + 0x00, 0x00, 0x00, 0x0C, // Length of 'test-content' 0x74, 0x65, 0x73, 0x74, // 0x2d, 0x63, 0x6f, 0x6e, // 'test-content' 0x74, 0x65, 0x6e, 0x74, // http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java index 9dc340a..80a67eb 100644 --- a/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java +++ b/nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/TestPersistentProvenanceRepository.java @@ -1980,7 +1980,7 @@ public class TestPersistentProvenanceRepository { final ProvenanceEventRecord record = builder.build(); try { repo.registerEvent(record); - Assert.fail("Expected OutOfMmeoryError but was able to register event"); + Assert.fail("Expected OutOfMemoryError but was able to register event"); } catch (final OutOfMemoryError oome) { } } @@ -1991,7 +1991,7 @@ public class TestPersistentProvenanceRepository { final ProvenanceEventRecord record = builder.build(); try { repo.registerEvent(record); - Assert.fail("Expected OutOfMmeoryError but was able to register event"); + Assert.fail("Expected OutOfMemoryError but was able to register event"); } catch (final IllegalStateException ise) { } } http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-ranger-bundle/nifi-ranger-plugin/src/test/java/org/apache/nifi/ranger/authorization/TestRangerNiFiAuthorizer.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-ranger-bundle/nifi-ranger-plugin/src/test/java/org/apache/nifi/ranger/authorization/TestRangerNiFiAuthorizer.java b/nifi-nar-bundles/nifi-ranger-bundle/nifi-ranger-plugin/src/test/java/org/apache/nifi/ranger/authorization/TestRangerNiFiAuthorizer.java index 1bfa1b3..46084c4 100644 --- a/nifi-nar-bundles/nifi-ranger-bundle/nifi-ranger-plugin/src/test/java/org/apache/nifi/ranger/authorization/TestRangerNiFiAuthorizer.java +++ b/nifi-nar-bundles/nifi-ranger-bundle/nifi-ranger-plugin/src/test/java/org/apache/nifi/ranger/authorization/TestRangerNiFiAuthorizer.java @@ -139,7 +139,7 @@ public class TestRangerNiFiAuthorizer { Assert.fail("Should have thrown exception"); } catch (AuthorizerCreationException e) { // want to make sure this exception is from our authorizer code - veryifyOnlyAuthorizerCreationExceptions(e); + verifyOnlyAuthorizeCreationExceptions(e); } } @@ -159,7 +159,7 @@ public class TestRangerNiFiAuthorizer { Assert.fail("Should have thrown exception"); } catch (AuthorizerCreationException e) { // want to make sure this exception is from our authorizer code - veryifyOnlyAuthorizerCreationExceptions(e); + verifyOnlyAuthorizeCreationExceptions(e); } } @@ -180,11 +180,11 @@ public class TestRangerNiFiAuthorizer { Assert.fail("Should have thrown exception"); } catch (AuthorizerCreationException e) { // want to make sure this exception is from our authorizer code - veryifyOnlyAuthorizerCreationExceptions(e); + verifyOnlyAuthorizeCreationExceptions(e); } } - private void veryifyOnlyAuthorizerCreationExceptions(AuthorizerCreationException e) { + private void verifyOnlyAuthorizeCreationExceptions(AuthorizerCreationException e) { boolean foundOtherException = false; Throwable cause = e.getCause(); while (cause != null) { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestGetTwitter.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestGetTwitter.java b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestGetTwitter.java index 132fa17..e56be67 100644 --- a/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestGetTwitter.java +++ b/nifi-nar-bundles/nifi-social-media-bundle/nifi-twitter-processors/src/test/java/org/apache/nifi/processors/twitter/TestGetTwitter.java @@ -28,7 +28,7 @@ public class TestGetTwitter { runner.setProperty(GetTwitter.ENDPOINT, GetTwitter.ENDPOINT_FILTER); runner.setProperty(GetTwitter.CONSUMER_KEY, "consumerKey"); runner.setProperty(GetTwitter.CONSUMER_SECRET, "consumerSecret"); - runner.setProperty(GetTwitter.ACCESS_TOKEN, "acessToken"); + runner.setProperty(GetTwitter.ACCESS_TOKEN, "accessToken"); runner.setProperty(GetTwitter.ACCESS_TOKEN_SECRET, "accessTokenSecret"); runner.setProperty(GetTwitter.LOCATIONS, "-122.75,36.8,-121.75,37.8,-74,40,-73,41"); runner.assertValid(); @@ -40,7 +40,7 @@ public class TestGetTwitter { runner.setProperty(GetTwitter.ENDPOINT, GetTwitter.ENDPOINT_FILTER); runner.setProperty(GetTwitter.CONSUMER_KEY, "consumerKey"); runner.setProperty(GetTwitter.CONSUMER_SECRET, "consumerSecret"); - runner.setProperty(GetTwitter.ACCESS_TOKEN, "acessToken"); + runner.setProperty(GetTwitter.ACCESS_TOKEN, "accessToken"); runner.setProperty(GetTwitter.ACCESS_TOKEN_SECRET, "accessTokenSecret"); runner.setProperty(GetTwitter.LOCATIONS, "-122.75,36.8,-121.75,37.8,-74,40,-73,40"); runner.assertNotValid(); @@ -52,7 +52,7 @@ public class TestGetTwitter { runner.setProperty(GetTwitter.ENDPOINT, GetTwitter.ENDPOINT_FILTER); runner.setProperty(GetTwitter.CONSUMER_KEY, "consumerKey"); runner.setProperty(GetTwitter.CONSUMER_SECRET, "consumerSecret"); - runner.setProperty(GetTwitter.ACCESS_TOKEN, "acessToken"); + runner.setProperty(GetTwitter.ACCESS_TOKEN, "accessToken"); runner.setProperty(GetTwitter.ACCESS_TOKEN_SECRET, "accessTokenSecret"); runner.setProperty(GetTwitter.LOCATIONS, "-122.75,36.8,-121.75,37.8,-74,40,-74,41"); runner.assertNotValid(); @@ -64,7 +64,7 @@ public class TestGetTwitter { runner.setProperty(GetTwitter.ENDPOINT, GetTwitter.ENDPOINT_FILTER); runner.setProperty(GetTwitter.CONSUMER_KEY, "consumerKey"); runner.setProperty(GetTwitter.CONSUMER_SECRET, "consumerSecret"); - runner.setProperty(GetTwitter.ACCESS_TOKEN, "acessToken"); + runner.setProperty(GetTwitter.ACCESS_TOKEN, "accessToken"); runner.setProperty(GetTwitter.ACCESS_TOKEN_SECRET, "accessTokenSecret"); runner.setProperty(GetTwitter.LOCATIONS, "-122.75,36.8,-121.75,37.8,-74,40,-73,39"); runner.assertNotValid(); @@ -76,7 +76,7 @@ public class TestGetTwitter { runner.setProperty(GetTwitter.ENDPOINT, GetTwitter.ENDPOINT_FILTER); runner.setProperty(GetTwitter.CONSUMER_KEY, "consumerKey"); runner.setProperty(GetTwitter.CONSUMER_SECRET, "consumerSecret"); - runner.setProperty(GetTwitter.ACCESS_TOKEN, "acessToken"); + runner.setProperty(GetTwitter.ACCESS_TOKEN, "accessToken"); runner.setProperty(GetTwitter.ACCESS_TOKEN_SECRET, "accessTokenSecret"); runner.setProperty(GetTwitter.LOCATIONS, "-122.75,36.8,-121.75,37.8,-74,40,-75,41"); runner.assertNotValid(); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java index 5b9f5b4..054d1d8 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutFileTransfer.java @@ -141,7 +141,7 @@ public abstract class PutFileTransfer<T extends FileTransfer> extends AbstractPr stopWatch.stop(); final String dataRate = stopWatch.calculateDataRate(flowFile.getSize()); final long millis = stopWatch.getDuration(TimeUnit.MILLISECONDS); - logger.info("Successfully transfered {} to {} on remote host {} in {} milliseconds at a rate of {}", + logger.info("Successfully transferred {} to {} on remote host {} in {} milliseconds at a rate of {}", new Object[]{flowFile, fullPathRef.get(), hostname, millis, dataRate}); String fullPathWithSlash = fullPathRef.get(); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java index 8e87c56..eb27d40 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/PutSQL.java @@ -89,12 +89,12 @@ import java.util.regex.Pattern; + "are needed to complete the transaction."), @ReadsAttribute(attribute = "fragment.index", description = "If the <Support Fragment Transactions> property is true, this attribute is used to determine the order that the FlowFiles " + "in a transaction should be evaluated."), - @ReadsAttribute(attribute = "sql.args.N.type", description = "Incoming FlowFiles are expected to be parameterized SQL statements. The type of each Parameter is specified as an integer " + @ReadsAttribute(attribute = "sql.args.N.type", description = "Incoming FlowFiles are expected to be parametrized SQL statements. The type of each Parameter is specified as an integer " + "that represents the JDBC Type of the parameter."), - @ReadsAttribute(attribute = "sql.args.N.value", description = "Incoming FlowFiles are expected to be parameterized SQL statements. The value of the Parameters are specified as " + @ReadsAttribute(attribute = "sql.args.N.value", description = "Incoming FlowFiles are expected to be parametrized SQL statements. The value of the Parameters are specified as " + "sql.args.1.value, sql.args.2.value, sql.args.3.value, and so on. The type of the sql.args.1.value Parameter is specified by the sql.args.1.type attribute."), @ReadsAttribute(attribute = "sql.args.N.format", description = "This attribute is always optional, but default options may not always work for your data. " - + "Incoming FlowFiles are expected to be parameterized SQL statements. In some cases " + + "Incoming FlowFiles are expected to be parametrized SQL statements. In some cases " + "a format option needs to be specified, currently this is only applicable for binary data types. For binary data types " + "available options are 'ascii', 'base64' and 'hex'. In 'ascii' format each string character in your attribute value represents a single byte, this is the default format " + "and the format provided by Avro Processors. In 'base64' format your string is a Base64 encoded string. In 'hex' format the string is hex encoded with all " http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java index a542048..9b20ec6 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ReplaceText.java @@ -93,7 +93,7 @@ public class ReplaceText extends AbstractProcessor { "Insert the Replacement Value at the beginning of the FlowFile or the beginning of each line (depending on the Evaluation Mode). For \"Line-by-Line\" Evaluation Mode, " + "the value will be prepended to each line. For \"Entire Text\" evaluation mode, the value will be prepended to the entire text."); static final AllowableValue APPEND = new AllowableValue(appendValue, appendValue, - "Insert the Replacement Value at the end of the FlowFile or the end of each line (depending on the Evluation Mode). For \"Line-by-Line\" Evaluation Mode, " + "Insert the Replacement Value at the end of the FlowFile or the end of each line (depending on the Evaluation Mode). For \"Line-by-Line\" Evaluation Mode, " + "the value will be appended to each line. For \"Entire Text\" evaluation mode, the value will be appended to the entire text."); static final AllowableValue LITERAL_REPLACE = new AllowableValue(literalReplaceValue, literalReplaceValue, "Search for all instances of the Search Value and replace the matches with the Replacement Value."); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteOnContent.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteOnContent.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteOnContent.java index 64877f2..5e0b892 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteOnContent.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/RouteOnContent.java @@ -64,7 +64,7 @@ import org.apache.nifi.stream.io.StreamUtils; + "content. User-Defined properties do support the Attribute Expression Language, but the results are interpreted as " + "literal values, not Regular Expressions") @DynamicProperty(name = "Relationship Name", value = "A Regular Expression", supportsExpressionLanguage = true, description = "Routes FlowFiles whose " - + "content matches the regular expressoin defined by Dynamic Property's value to the Relationship defined by the Dynamic Property's key") + + "content matches the regular expression defined by Dynamic Property's value to the Relationship defined by the Dynamic Property's key") @DynamicRelationship(name = "Name from Dynamic Property", description = "FlowFiles that match the Dynamic Property's Regular Expression") public class RouteOnContent extends AbstractProcessor { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TransformXml.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TransformXml.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TransformXml.java index e90a3a1..cb5726a 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TransformXml.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/TransformXml.java @@ -263,11 +263,11 @@ public class TransformXml extends AbstractProcessor { } else { String error = null; final File stylesheet = new File(input); - final TransformerFactory tfactory = new net.sf.saxon.TransformerFactoryImpl(); + final TransformerFactory tFactory = new net.sf.saxon.TransformerFactoryImpl(); final StreamSource styleSource = new StreamSource(stylesheet); try { - tfactory.newTransformer(styleSource); + tFactory.newTransformer(styleSource); } catch (final Exception e) { error = e.toString(); } http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/PGPUtil.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/PGPUtil.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/PGPUtil.java index 7482640..8f66461 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/PGPUtil.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/util/PGPUtil.java @@ -65,7 +65,7 @@ public class PGPUtil { } try { - // TODO: Can probably hardcode provider to BC and remove one method parameter + // TODO: Can probably hard-code provider to BC and remove one method parameter PGPEncryptedDataGenerator encryptedDataGenerator = new PGPEncryptedDataGenerator( new JcePGPDataEncryptorBuilder(cipher).setWithIntegrityPacket(true).setSecureRandom(new SecureRandom()).setProvider(provider)); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestExecuteSQL.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestExecuteSQL.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestExecuteSQL.java index 5e2a64a..ebca87e 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestExecuteSQL.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestExecuteSQL.java @@ -189,7 +189,7 @@ public class TestExecuteSQL { stmt.execute("create table TEST_NO_ROWS (id integer)"); runner.setIncomingConnection(false); - // Try a valid SQL statment that will generate an error (val1 does not exist, e.g.) + // Try a valid SQL statement that will generate an error (val1 does not exist, e.g.) runner.setProperty(ExecuteSQL.SQL_SELECT_QUERY, "SELECT val1 FROM TEST_NO_ROWS"); runner.run(); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestInvokeHTTP.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestInvokeHTTP.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestInvokeHTTP.java index 84292cc..d08f083 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestInvokeHTTP.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestInvokeHTTP.java @@ -140,7 +140,7 @@ public class TestInvokeHTTP extends TestInvokeHttpCommon { runner.run(); Assert.fail(); } catch (AssertionError e){ - // Expect assetion error when proxy port isn't set but host is. + // Expect assertion error when proxy port isn't set but host is. } runner.setProperty(InvokeHTTP.PROP_PROXY_PORT, String.valueOf(proxyURL.getPort())); @@ -150,7 +150,7 @@ public class TestInvokeHTTP extends TestInvokeHttpCommon { runner.run(); Assert.fail(); } catch (AssertionError e){ - // Expect assetion error when proxy password isn't set but host is. + // Expect assertion error when proxy password isn't set but host is. } runner.setProperty(InvokeHTTP.PROP_PROXY_PASSWORD, "password"); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java index 413ac7c..f96ff22 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenSyslog.java @@ -89,15 +89,15 @@ public class TestListenSyslog { // call onTrigger until we read all datagrams, or 30 seconds passed try { - int numTransfered = 0; + int numTransferred = 0; long timeout = System.currentTimeMillis() + 30000; - while (numTransfered < numMessages && System.currentTimeMillis() < timeout) { + while (numTransferred < numMessages && System.currentTimeMillis() < timeout) { Thread.sleep(10); proc.onTrigger(context, processSessionFactory); - numTransfered = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); + numTransferred = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); } - Assert.assertEquals("Did not process all the datagrams", numMessages, numTransfered); + Assert.assertEquals("Did not process all the datagrams", numMessages, numTransferred); MockFlowFile flowFile = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).get(0); checkFlowFile(flowFile, 0, ListenSyslog.UDP_VALUE.getValue()); @@ -142,15 +142,15 @@ public class TestListenSyslog { // call onTrigger until we read all messages, or 30 seconds passed try { - int numTransfered = 0; + int nubTransferred = 0; long timeout = System.currentTimeMillis() + 30000; - while (numTransfered < numMessages && System.currentTimeMillis() < timeout) { + while (nubTransferred < numMessages && System.currentTimeMillis() < timeout) { Thread.sleep(10); proc.onTrigger(context, processSessionFactory); - numTransfered = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); + nubTransferred = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); } - Assert.assertEquals("Did not process all the messages", numMessages, numTransfered); + Assert.assertEquals("Did not process all the messages", numMessages, nubTransferred); MockFlowFile flowFile = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).get(0); checkFlowFile(flowFile, 0, ListenSyslog.TCP_VALUE.getValue()); @@ -193,15 +193,15 @@ public class TestListenSyslog { // call onTrigger until we read all messages, or 30 seconds passed try { - int numTransfered = 0; + int nubTransferred = 0; long timeout = System.currentTimeMillis() + 30000; - while (numTransfered < numMessages && System.currentTimeMillis() < timeout) { + while (nubTransferred < numMessages && System.currentTimeMillis() < timeout) { Thread.sleep(10); proc.onTrigger(context, processSessionFactory); - numTransfered = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); + nubTransferred = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); } - Assert.assertEquals("Did not process all the messages", numMessages, numTransfered); + Assert.assertEquals("Did not process all the messages", numMessages, nubTransferred); MockFlowFile flowFile = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).get(0); checkFlowFile(flowFile, 0, ListenSyslog.TCP_VALUE.getValue()); @@ -244,15 +244,15 @@ public class TestListenSyslog { // call onTrigger until we read all messages, or 30 seconds passed try { - int numTransfered = 0; + int nubTransferred = 0; long timeout = System.currentTimeMillis() + 30000; - while (numTransfered < numMessages && System.currentTimeMillis() < timeout) { + while (nubTransferred < numMessages && System.currentTimeMillis() < timeout) { Thread.sleep(10); proc.onTrigger(context, processSessionFactory); - numTransfered = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); + nubTransferred = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).size(); } - Assert.assertEquals("Did not process all the messages", numMessages, numTransfered); + Assert.assertEquals("Did not process all the messages", numMessages, nubTransferred); MockFlowFile flowFile = runner.getFlowFilesForRelationship(ListenSyslog.REL_SUCCESS).get(0); checkFlowFile(flowFile, 0, ListenSyslog.TCP_VALUE.getValue()); @@ -347,17 +347,17 @@ public class TestListenSyslog { // call onTrigger until we read all messages, or 30 seconds passed try { - int numTransfered = 0; + int nubTransferred = 0; long timeout = System.currentTimeMillis() + 30000; - while (numTransfered < numMessages && System.currentTimeMillis() < timeout) { + while (nubTransferred < numMessages && System.currentTimeMillis() < timeout) { Thread.sleep(50); proc.onTrigger(context, processSessionFactory); - numTransfered = runner.getFlowFilesForRelationship(ListenSyslog.REL_INVALID).size(); + nubTransferred = runner.getFlowFilesForRelationship(ListenSyslog.REL_INVALID).size(); } // all messages should be transferred to invalid - Assert.assertEquals("Did not process all the messages", numMessages, numTransfered); + Assert.assertEquals("Did not process all the messages", numMessages, nubTransferred); } finally { // unschedule to close connections http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java index d94d4ac..b6c997e 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListenUDP.java @@ -172,7 +172,7 @@ public class TestListenUDP { } @Test - public void testRunWhenNoEventsAvailale() throws IOException, InterruptedException { + public void testRunWhenNoEventsAvailable() throws IOException, InterruptedException { final List<StandardEvent> mockEvents = new ArrayList<>(); MockListenUDP mockListenUDP = new MockListenUDP(mockEvents); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMergeContent.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMergeContent.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMergeContent.java index cd06ba0..e738759 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMergeContent.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMergeContent.java @@ -107,7 +107,7 @@ public class TestMergeContent { final MockFlowFile bundle = runner.getFlowFilesForRelationship(MergeContent.REL_MERGED).get(0); bundle.assertAttributeEquals(CoreAttributes.MIME_TYPE.key(), "application/avro-binary"); - // create a reader for the merged contet + // create a reader for the merged content byte[] data = runner.getContentAsByteArray(bundle); final Map<String, GenericRecord> users = getGenericRecordMap(data, schema, "name"); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMonitorActivity.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMonitorActivity.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMonitorActivity.java index 9e08e86..bd375e4 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMonitorActivity.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestMonitorActivity.java @@ -223,7 +223,7 @@ public class TestMonitorActivity { List<MockFlowFile> inactiveFlowFiles = runner.getFlowFilesForRelationship(MonitorActivity.REL_INACTIVE); if (inactiveFlowFiles.size() == 1) { // Seems Threshold was not sufficient, which has caused One inactive message. - // Step-up and rerun the test until successful or jUnit Timesout + // Step-up and rerun the test until successful or jUnit times out threshold += threshold; rerun = true; } else { http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutDistributedMapCache.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutDistributedMapCache.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutDistributedMapCache.java index 05d4293..9bd649b 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutDistributedMapCache.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestPutDistributedMapCache.java @@ -53,7 +53,7 @@ public class TestPutDistributedMapCache { @Test public void testNoCacheKey() throws InitializationException { - runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${caheKeyAttribute}"); + runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${cacheKeyAttribute}"); runner.enqueue(new byte[] {}); runner.run(); @@ -66,10 +66,10 @@ public class TestPutDistributedMapCache { @Test public void testSingleFlowFile() throws InitializationException, IOException { - runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${caheKeyAttribute}"); + runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${cacheKeyAttribute}"); final Map<String, String> props = new HashMap<>(); - props.put("caheKeyAttribute", "1"); + props.put("cacheKeyAttribute", "1"); String flowFileContent = "content"; runner.enqueue(flowFileContent.getBytes("UTF-8"), props); @@ -90,10 +90,10 @@ public class TestPutDistributedMapCache { @Test public void testNothingToCache() throws InitializationException, IOException { - runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${caheKeyAttribute}"); + runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${cacheKeyAttribute}"); final Map<String, String> props = new HashMap<>(); - props.put("caheKeyAttribute", "2"); + props.put("cacheKeyAttribute", "2"); // flow file without content runner.enqueue(new byte[] {}, props); @@ -132,11 +132,11 @@ public class TestPutDistributedMapCache { @Test public void testCacheStrategyReplace() throws InitializationException, IOException { - runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${caheKeyAttribute}"); + runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${cacheKeyAttribute}"); runner.setProperty(PutDistributedMapCache.CACHE_UPDATE_STRATEGY, PutDistributedMapCache.CACHE_UPDATE_REPLACE.getValue()); final Map<String, String> props = new HashMap<>(); - props.put("caheKeyAttribute", "replaceme"); + props.put("cacheKeyAttribute", "replaceme"); String original = "original"; runner.enqueue(original.getBytes("UTF-8"), props); @@ -176,11 +176,11 @@ public class TestPutDistributedMapCache { @Test public void testCacheStrategyKeepOriginal() throws InitializationException, IOException { - runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${caheKeyAttribute}"); + runner.setProperty(PutDistributedMapCache.CACHE_ENTRY_IDENTIFIER, "${cacheKeyAttribute}"); runner.setProperty(PutDistributedMapCache.CACHE_UPDATE_STRATEGY, PutDistributedMapCache.CACHE_UPDATE_KEEP_ORIGINAL.getValue()); final Map<String, String> props = new HashMap<>(); - props.put("caheKeyAttribute", "replaceme"); + props.put("cacheKeyAttribute", "replaceme"); String original = "original"; runner.enqueue(original.getBytes("UTF-8"), props); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestReplaceText.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestReplaceText.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestReplaceText.java index b65bff1..94937de 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestReplaceText.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestReplaceText.java @@ -84,7 +84,7 @@ public class TestReplaceText { } @Test - public void testWithUnEscaped$InReplacemenmt() throws IOException { + public void testWithUnEscaped$InReplacement() throws IOException { final TestRunner runner = TestRunners.newTestRunner(new ReplaceText()); runner.setValidateExpressionUsage(false); runner.setProperty(ReplaceText.SEARCH_VALUE, "(?s:^.*$)"); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestScanContent.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestScanContent.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestScanContent.java index 4b87387..e6fedd3 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestScanContent.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestScanContent.java @@ -81,7 +81,7 @@ public class TestScanContent { while (!runner.isQueueEmpty()) { runner.run(3); - try { //must insert this deley or flowfiles are made so close together they become out of order in the queu + try { //must insert this delay or flowfiles are made so close together they become out of order in the queue Thread.sleep(500); } catch (InterruptedException ex) { //moving on http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/src/main/java/org/apache/nifi/ssl/StandardSSLContextService.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/src/main/java/org/apache/nifi/ssl/StandardSSLContextService.java b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/src/main/java/org/apache/nifi/ssl/StandardSSLContextService.java index 81be148..9817532 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/src/main/java/org/apache/nifi/ssl/StandardSSLContextService.java +++ b/nifi-nar-bundles/nifi-standard-services/nifi-ssl-context-bundle/nifi-ssl-context-service/src/main/java/org/apache/nifi/ssl/StandardSSLContextService.java @@ -456,7 +456,7 @@ public class StandardSSLContextService extends AbstractControllerService impleme final int numProtocols = supportedProtocols.size(); - // Sort for consistent presentation in configuraiton views + // Sort for consistent presentation in configuration views final List<String> supportedProtocolList = new ArrayList<>(supportedProtocols); Collections.sort(supportedProtocolList); http://git-wip-us.apache.org/repos/asf/nifi/blob/3b408f56/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java b/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java index d267bf7..08f4ee9 100644 --- a/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java +++ b/nifi-nar-bundles/nifi-update-attribute-bundle/nifi-update-attribute-processor/src/main/java/org/apache/nifi/processors/attributes/UpdateAttribute.java @@ -351,7 +351,7 @@ public class UpdateAttribute extends AbstractProcessor implements Searchable { // is cloned for each matching rule. in 'use original' mode, this collection // will contain a single entry that maps a list of multiple rules. this is // because is the original flowfile is used for all matching rules. in this - // case the order of the matching rules is perserved in the list + // case the order of the matching rules is preserved in the list final Map<FlowFile, List<Rule>> matchedRules = new HashMap<>(); for (FlowFile flowFile : flowFiles) {
