This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to branch support/nifi-1.19
in repository https://gitbox.apache.org/repos/asf/nifi.git
from ff9ae733d6 NIFI-10913 updating all to 1.19.1-snapshot. line builds
and ready
new 3caad988be NIFI-10866 Refactored Kafka 1.0 and 2.0 using
nifi-kafka-shared
new 2834aab432 NIFI-10850: Fixed Query Parameters property in
InvokeAWSGatewayApi should support FlowFile attributes in EL
new 0a09aa57fd NIFI-6428 Add 'inTransaction' value to state,fix bug
new 51395bddd1 NIFI-10845 - JsonQueryElasticsearch processors are not
outputting an empty flow file for a combined response with output_no_hits set
to true
new db2bf5f645 NIFI-5819: Support SQLServer sql_variant type
new e0b4feac57 NIFI-10873 - GenerateFlowFile: flowfiles in a batch are not
unique
new 69e4786666 NIFI-10874 Fixed issue with multiple levels of versioned
flows
new bfa59b2041 NIFI-10872 Fix broken Java Mail links in ConsumeIMAP and
ConsumePOP3 documentation
new 83d9f9916a NIFI-10886 Upgraded PostgreSQL JDBC Driver from 42.4.1 to
42.4.3
new 0ed8114dcb NIFI-7190 CaptureChangeMySQL processor remove comments from
normalized query
new d502831559 NIFI-10882 Set credentials for ElasticSearchClientService
based on AuthorizationScheme
new 2e6f8ecbe0 NIFI-10875 Changed TestQuerySolr to check for path elements
new 03933c6425 NIFI-10834 Updated TestPutSplunkHTTP to avoid
non-deterministic tests
new ec813fc445 NIFI-10859 Upgraded metrics-jvm from 4.1.2 to 4.1.33
new 4aa86b850d NIFI-10871 Skipped CSRF processing for replicated HTTP
requests
new 71f41b96ba NIFI-10785 Allow publishing AMQP message with null header
value NIFI-10785 addressing review comment NIFI-10785 addressing review
comments (remove unnecessary property to ignore null headers)
new e6dfea6352 NIFI-10890 Replaced HashMap with LinkedHashMap in
JsonRowRecordReader
new 8c74f54b9d NIFI-10891 Replaced HashMap with LinkedHashMap in BinFiles
new c36c4c0bbc NIFI-10765 Added better error reporting in JASN1Reader
new 8e0eeded00 NIFI-10910 Upgraded amqp-client from 5.15.0 to 5.16.0
new 6808a5944d NIFI-10901 - PublishKafka headers not sent in
ProducerRecord (#6731)
new eb0d07fda3 NIFI-10913 updating versions post commit landing
The 22 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
nifi-commons/nifi-metrics/pom.xml | 4 +-
.../nifi-amqp-bundle/nifi-amqp-processors/pom.xml | 2 +-
.../apache/nifi/amqp/processors/PublishAMQP.java | 78 ++-
.../nifi/amqp/processors/PublishAMQPTest.java | 111 ++--
.../nifi-asn1-bundle/nifi-asn1-services/pom.xml | 34 +-
.../asn1bean/compiler/BerClassWriterFactory.java | 37 ++
.../java/org/apache/nifi/jasn1/JASN1Reader.java | 97 +++-
.../additionalDetails.html | 66 ++-
.../org/apache/nifi/jasn1/JASN1ReaderTest.java | 152 +++++-
.../src/test/resources/cant_compile.asn | 12 +
.../test/resources/cant_compile_mac_windows.asn | 11 +
.../src/test/resources/cant_parse.asn | 21 +
.../aws/wag/AbstractAWSGatewayApiProcessor.java | 9 +-
.../aws/wag/TestInvokeAmazonGatewayApiMock.java | 5 +-
.../cdc/mysql/processors/CaptureChangeMySQL.java | 42 +-
.../mysql/processors/CaptureChangeMySQLTest.groovy | 56 ++-
.../ElasticSearchClientServiceImpl.java | 10 +-
.../AbstractJsonQueryElasticsearch.java | 8 +-
.../AbstractPaginatedJsonQueryElasticsearch.java | 3 +
...tractPaginatedJsonQueryElasticsearchTest.groovy | 39 ++
.../additionalDetails.html | 2 +-
.../additionalDetails.html | 2 +-
.../apache/nifi/processor/util/bin/BinFiles.java | 4 +-
.../java/org/apache/nifi/util/db/JdbcCommon.java | 5 +
.../nifi/json/AbstractJsonRowRecordReader.java | 8 +-
.../nifi/web/NiFiWebApiSecurityConfiguration.java | 2 +
.../apache/nifi/web/api/ProcessGroupResource.java | 11 +-
.../org/apache/nifi/web/api/dto/DtoFactory.java | 2 +
.../security/csrf/SkipReplicatedCsrfFilter.java | 61 +++
.../csrf/SkipReplicatedCsrfFilterTest.java | 113 +++++
.../nifi-kafka-1-0-processors/pom.xml | 13 +
.../kafka/pubsub/ConsumeKafkaRecord_1_0.java | 50 +-
.../processors/kafka/pubsub/ConsumeKafka_1_0.java | 58 ++-
.../processors/kafka/pubsub/ConsumerLease.java | 58 +--
.../kafka/pubsub/KafkaProcessorUtils.java | 405 ---------------
.../kafka/pubsub/PublishKafkaRecord_1_0.java | 72 ++-
.../processors/kafka/pubsub/PublishKafka_1_0.java | 63 +--
.../record/sink/kafka/KafkaRecordSink_1_0.java | 131 +----
.../processors/kafka/pubsub/ConsumeKafkaTest.java | 43 +-
.../processors/kafka/pubsub/ConsumerPoolTest.java | 15 +-
.../processors/kafka/pubsub/ITConsumeKafka.java | 12 +-
.../kafka/pubsub/TestConsumeKafkaRecord_1_0.java | 33 +-
.../record/sink/kafka/TestKafkaRecordSink_1_0.java | 12 +-
.../src/test/resources/log4j.properties | 21 -
.../src/test/resources/zookeeper.properties | 20 -
.../nifi-kafka-2-0-processors/pom.xml | 14 +-
.../kafka/pubsub/ConsumeKafkaRecord_2_0.java | 61 +--
.../processors/kafka/pubsub/ConsumeKafka_2_0.java | 65 ++-
.../processors/kafka/pubsub/ConsumerLease.java | 41 +-
.../kafka/pubsub/KafkaProcessorUtils.java | 557 ---------------------
.../kafka/pubsub/PublishKafkaRecord_2_0.java | 83 ++-
.../processors/kafka/pubsub/PublishKafka_2_0.java | 73 +--
.../record/sink/kafka/KafkaRecordSink_2_0.java | 128 +----
.../kafka/pubsub/ITConsumeKafka_2_0.java | 12 +-
.../kafka/pubsub/TestConsumeKafkaRecord_2_0.java | 64 ++-
.../kafka/pubsub/TestConsumeKafka_2_0.java | 43 +-
.../kafka/pubsub/TestConsumerPartitionsUtil.java | 2 +-
.../kafka/pubsub/TestPublishKafkaRecord_2_0.java | 9 +-
.../kafka/pubsub/TestPublishKafka_2_0.java | 7 +-
.../record/sink/kafka/TestKafkaRecordSink_2_0.java | 14 +-
.../src/test/resources/log4j.properties | 21 -
.../processors/kafka/pubsub/PublisherLease.java | 3 +-
.../additionalDetails.html | 2 +-
.../pubsub/TestPublishKafkaMockParameterized.java | 97 ++--
...> TestPublishKafkaRecordMockParameterized.java} | 49 +-
.../parameterized/flowfileInput1.json | 0
.../parameterized/flowfileInputA.json | 0
.../Publish/parameterized/kafkaOutput1A.json | 18 +
.../Publish/parameterized/kafkaOutput1B.json | 18 +
.../Publish/parameterized/kafkaOutputA1.json | 22 +
.../Publish/parameterized/kafkaOutputA2.json | 22 +
...flowfileInput1.json => flowfileInputDoc1V.json} | 0
.../parameterized/flowfileInputDoc1W.json | 15 +
.../parameterized/flowfileInputDoc2W.json | 15 +
.../parameterized/kafkaOutputDoc1V.json | 21 +
.../parameterized/kafkaOutputDoc1W.json | 18 +
.../parameterized/kafkaOutputDoc2W.json | 16 +
.../apache/nifi/processors/solr/TestQuerySolr.java | 24 +-
.../nifi/processors/splunk/TestPutSplunkHTTP.java | 5 +-
.../nifi/processors/standard/GenerateFlowFile.java | 22 +-
.../processors/standard/PutDatabaseRecord.java | 8 +
.../nifi/json/TestJsonTreeRowRecordReader.java | 2 +-
.../nifi-registry-core/nifi-registry-test/pom.xml | 2 +-
83 files changed, 1660 insertions(+), 1926 deletions(-)
create mode 100644
nifi-nar-bundles/nifi-asn1-bundle/nifi-asn1-services/src/main/java/com/beanit/asn1bean/compiler/BerClassWriterFactory.java
create mode 100644
nifi-nar-bundles/nifi-asn1-bundle/nifi-asn1-services/src/test/resources/cant_compile.asn
create mode 100644
nifi-nar-bundles/nifi-asn1-bundle/nifi-asn1-services/src/test/resources/cant_compile_mac_windows.asn
create mode 100644
nifi-nar-bundles/nifi-asn1-bundle/nifi-asn1-services/src/test/resources/cant_parse.asn
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/main/java/org/apache/nifi/web/security/csrf/SkipReplicatedCsrfFilter.java
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-security/src/test/java/org/apache/nifi/web/security/csrf/SkipReplicatedCsrfFilterTest.java
delete mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
delete mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/test/resources/log4j.properties
delete mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-1-0-processors/src/test/resources/zookeeper.properties
delete mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/main/java/org/apache/nifi/processors/kafka/pubsub/KafkaProcessorUtils.java
delete mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-0-processors/src/test/resources/log4j.properties
copy
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/java/org/apache/nifi/processors/kafka/pubsub/{TestPublishKafkaMockParameterized.java
=> TestPublishKafkaRecordMockParameterized.java} (86%)
copy
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/{PublishRecord
=> Publish}/parameterized/flowfileInput1.json (100%)
copy
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/{PublishRecord
=> Publish}/parameterized/flowfileInputA.json (100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/Publish/parameterized/kafkaOutput1A.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/Publish/parameterized/kafkaOutput1B.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/Publish/parameterized/kafkaOutputA1.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/Publish/parameterized/kafkaOutputA2.json
copy
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/{flowfileInput1.json
=> flowfileInputDoc1V.json} (100%)
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/flowfileInputDoc1W.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/flowfileInputDoc2W.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutputDoc1V.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutputDoc1W.json
create mode 100644
nifi-nar-bundles/nifi-kafka-bundle/nifi-kafka-2-6-processors/src/test/resources/PublishRecord/parameterized/kafkaOutputDoc2W.json
