nifi-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From joew...@apache.org
Subject [nifi] branch support/nifi-1.9.x updated (5e9f8f7 -> 5cad3e5)
Date Tue, 12 Mar 2019 19:39:52 GMT
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


Mime
View raw message