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
|