This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to branch support/nifi-1.9.x
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 5e9f8f7 NIFI-6116 update versions to snapshot to prepare for adding
commits
new 135f19b NIFI-6110: Updated StandardProcessSession such that if we
fail to update the FlowFile Repository, we do not decrement claimant counts for
any FlowFiles that were removed. Doing so can cause an issue where a FlowFile
is removed, then the FlowFileRepo update fails, resulting in the flowfile being
rolled back, but after its claimant count is decremented. It will then be
processed again, which can result in the same thing, and we'll end up
decrementing the claimant count rep [...]
new c009927 NIFI-6108: Fix port names when imported from registry
new df0a5f9 NIFI-3685 Azure EventHub processor tests fail
new e873d68 NIFI-5660: JMSPublisher should set some header properties in
JmsTemplate instead of directly in the message NIFI-5660: Added lines to
integration test to verify these header properties (added by Mike Moser)
new d99db83 NIFI-5977 - Add "Minimum/Maximum File Age" Parameter to
ListSFTP
new ffb268f NIFI-5987 Fixed issue where an invalid query pulled from an
attribute would cause GetMongo to not route to failure.
new 04dc1d6 NIFI-6040: Fixed ExecuteSQL processors when Output Batch Size
is set
new 81cc454 NIFI-6052 Update NOTICE files to reflect 2019
new e901fca NIFI-6059 - Fixed NPE in GCS processors when project ID is
not specified
new b3cc626 NIFI-6068, NIFI-6065: Updated StandardFunnel to avoid looping
indefinitely and instead transfer no more than 10,000 FlowFiles before
returning from onTrigger. Updated Local Ports to behavior in the same way.
Updated Root Group Ports so that instead of blocking for up to 100 milliseconds
for an incoming request, it blocks for up to 1 millisecond and if nothing is
available yields for the 'bored yield duration'
new 13d4f87 NIFI-6068: Fixed unit test
new 3ab55b6 NIFI-6069 Fixing fingerprinting of connection relationships
to be properly sorted
new f31f400 NIFI-6069 Fixing checkstyle error
new 9874804 NIFI-6076 syslog5424 should support missing MSG - newer lib
version and better test
new eb763a3 NIFI-6088: Widen type inference for BIGINT and DOUBLE
new ca32e04 NIFI-6111: Fixed bugs in the Status History values. If
metrics are not available yet from all nodes for the last point on the graph,
leave the cluster aggregate value off for the last point to prevent it from
dropping significantly at the end of the chart. Fixed bug where counter values
were not properly summed together in cluster view. Addressed issue with Average
Task Duration
new 4f01a5c NIFI-6055 Improving error handling during auto-loading of
NARs and ensuring only one Jetty NAR is loaded
new e1c8fc0 NIFI-6103 Fixed README documentation to indicate JDK 1.8 is
required.
new 7d8243d NIFI-6062: Add support for BLOB, CLOB, NCLOB in record
handling
new 5790bcc NIFI-2738 Removed references to
nifi.cluster.request.replication.claim.timeout
new 5cad3e5 NIFI-6116 fixed snapshot versions
The 21 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:
NOTICE | 2 +-
README.md | 2 +-
.../serialization/record/util/DataTypeUtils.java | 69 +++++-
.../apache/nifi/wali/LengthDelimitedJournal.java | 8 +-
.../nifi/wali/TestLengthDelimitedJournal.java | 93 ++++++--
.../src/test/java/org/wali/DummyRecordSerde.java | 14 +-
nifi-docs/NOTICE | 2 +-
.../src/main/asciidoc/administration-guide.adoc | 9 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../azure/eventhub/GetAzureEventHubTest.java | 75 +++++--
.../azure/eventhub/PutAzureEventHubTest.java | 4 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi-cassandra-processors/pom.xml | 6 +-
.../cassandra/AbstractCassandraProcessor.java | 3 +-
.../cassandra/AbstractCassandraProcessorTest.java | 3 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resource/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../java/org/apache/nifi/avro/AvroTypeUtil.java | 16 +-
.../nifi-extension-utils/nifi-syslog-utils/pom.xml | 2 +-
.../syslog/BaseStrictSyslog5424ParserTest.java | 29 ++-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../endpoints/StatusHistoryEndpointMerger.java | 22 +-
.../org/apache/nifi/controller/StandardFunnel.java | 11 +-
.../org/apache/nifi/connectable/LocalPort.java | 38 ++--
.../repository/StandardProcessSession.java | 38 ++--
.../status/history/StandardStatusSnapshot.java | 7 +-
.../nifi/fingerprint/FingerprintFactory.java | 31 +--
.../apache/nifi/groups/StandardProcessGroup.java | 35 +--
.../org/apache/nifi/util/ComponentMetrics.java | 6 +-
.../repository/TestStandardProcessSession.java | 55 +++++
.../nifi/fingerprint/FingerprintFactoryTest.java | 44 ++--
.../flow-connection-with-multiple-rels.xml | 40 ++++
.../org/apache/nifi/nar/StandardNarLoader.java | 7 +-
.../nar/StandardExtensionDiscoveringManager.java | 58 ++---
.../java/org/apache/nifi/nar/NarUnpackerTest.java | 19 +-
.../NarUnpacker/lib/nifi-jetty-bundle.nar | Bin 0 -> 475 bytes
.../main/java/org/apache/nifi/nar/NarUnpacker.java | 37 +++-
.../nifi-framework/nifi-resources/NOTICE | 2 +-
.../nifi-framework/nifi-resources/pom.xml | 2 -
.../resources/NiFiProperties/conf/nifi.properties | 3 -
...h_sensitive_properties_protected_aes.properties | 3 -
...nsitive_properties_protected_aes_128.properties | 3 -
...operties_protected_aes_different_key.properties | 3 -
...ties_protected_aes_different_key_128.properties | 3 -
.../apache/nifi/remote/StandardRootGroupPort.java | 5 +-
.../nifi/remote/TestStandardRootGroupPort.java | 8 +-
.../test/resources/site-to-site/nifi.properties | 3 -
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi-web-ui/src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../gcp/storage/AbstractGCSProcessor.java | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi-grpc-nar/src/main/resources/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi/jms/processors/AbstractJMSProcessor.java | 5 +
.../apache/nifi/jms/processors/JMSPublisher.java | 9 +-
.../jms/processors/JMSPublisherConsumerIT.java | 4 +
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../mongodb/AbstractMongoQueryProcessor.java | 7 +-
.../apache/nifi/processors/mongodb/GetMongo.java | 12 +-
.../apache/nifi/processors/mongodb/GetMongoIT.java | 57 +++++
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi-standard-processors/pom.xml | 6 +
.../processors/standard/AbstractExecuteSQL.java | 5 +
.../apache/nifi/processors/standard/ListSFTP.java | 57 +++++
.../nifi/processors/standard/TestExecuteSQL.java | 45 ++++
.../processors/standard/TestExecuteSQLRecord.java | 240 ++++++++++++++++++---
.../nifi/processors/standard/TestListSFTP.java | 126 +++++++++++
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../nifi-record-serialization-services/pom.xml | 1 +
.../org/apache/nifi/json/JsonSchemaInference.java | 6 +-
.../apache/nifi/json/TestJsonSchemaInference.java | 84 ++++++++
.../src/test/resources/json/data-types.json | 24 +++
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
.../src/main/resources/META-INF/NOTICE | 2 +-
nifi-nar-bundles/pom.xml | 12 ++
nifi-toolkit/nifi-toolkit-assembly/NOTICE | 2 +-
.../src/test/resources/localhost/nifi.properties | 3 -
169 files changed, 1347 insertions(+), 394 deletions(-)
rename nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/{ =>
java}/org/apache/nifi/processors/azure/eventhub/GetAzureEventHubTest.java (69%)
rename nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/test/{ =>
java}/org/apache/nifi/processors/azure/eventhub/PutAzureEventHubTest.java (98%)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-core/src/test/resources/nifi/fingerprint/flow-connection-with-multiple-rels.xml
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-framework/nifi-framework-nar-utils/src/test/resources/NarUnpacker/lib/nifi-jetty-bundle.nar
create mode 100644
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/TestListSFTP.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/java/org/apache/nifi/json/TestJsonSchemaInference.java
create mode 100644
nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/test/resources/json/data-types.json
