This is an automated email from the ASF dual-hosted git repository.
joewitt pushed a change to branch support/nifi-1.13
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 1cd8e4a NIFI-8257 prepping versions for 1.13.1
new 0394f68 NIFI-3383 Check if usage operations are supported in
MonitorMemory
new 0d30a7b NIFI-8231 Clarify behavior of allowed values for Memory Pools
in MonitorMemory
new 877cc26 NIFI-8235 UnsupportedOpertationException in PutAccumuloRecord
new 715133f NIFI-5623 Upgraded OkHttp3 to 4.9.1 and updated unit tests
new d617e8f NIFI-8238: When FlowFile Concurrency/Outbound Policy is
changed on child group, and child group is directly under version control,
ensure that those fields are maintained on the generated VersionedProcessGroup
when nested components are stripped out
new c7d6dfc NIFI-8240: Unify Kudu versions
new e57bc69 NIFI-8200 Modified PutAzureDataLakeStorage to delete temp
file if exception was thrown in uploadContent()
new a2d428b NIFI-3669 Add SSL Support to CaptureChangeMySQL
new 414e6e6 NIFI-8242 Ensure NiFi URL for redirects has a trailing slash
in AccessResource
new d0ec044 NIFI-7496: Regex pattern changed to match dashes in filters.
new 1955e7a NIFI-5906 - Removed FILE_EXISTS_VALIDATOR on JARs and Files
to be added in the session
new 2f7b43a NIFI-8241 This closes #4833. Set the SAML context provider to
use the EmptyStorageFactory
new 2eb8cf9 NIFI-8232 CSV Parsers optionally allow/reject duplicate
header names
new 2fd8b20 NIFI-8250 - This closes #4838. UTF8 encoding for FTP
processors
new 2d61394 NIFI-8237: This closes #4835. Added missing SQL types to
getDataTypeFromSQLTypeValue(), added defensive code
new ae4bc01 NIFI-7646, NIFI-8222: Instead of having
StandardProcessSession call ContentRepository.read(ContentClaim), introduced a
new ContentRepository.read(ResourceClaim) and hold open the InputStream to the
ResourceClaim. This can't be supported by EncryptedContentRepository, so
introduced a method to allow using this or not. The benefit here is that when
we have many FlowFiles read within a session, such as when using
MergeContent/MergeRecord or a processor configured with a Run [...]
new 2d70644 NIFI-8205: Documentation improvements for the Wait processor
new 8ad6cdb NIFI-8119: properly free database resources when done with
the processing of BLOBs
new 80bb8c2 NIFI-8198: ConsumeAMQP detects if Queue is deleted on server
new f44e9a1 NIFI-8253: Restore call to session.commit() in
GenerateTableFetch
new 2cb5c3f NIFI-6113 Refactoring GetHDFSFileInfo to remove instance
level variable to make it stateless.
new 2e58491 NIFI-8249: Fixed issue with error during multiple FlowFile
results in ExecuteSQL processors
new 5847deb NIFI-3669 fixing incorrect pom merging of original commit
new 6a843eb NIFI-8257 have to remove grpc nar to save space
The 24 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-assembly/pom.xml | 17 -
nifi-bootstrap/pom.xml | 4 +-
.../notification/http/HttpNotificationService.java | 25 +-
.../http/HttpNotificationServiceTest.java | 242 ++++++++++++
.../http/TestHttpNotificationService.java | 61 ---
.../http/TestHttpNotificationServiceCommon.java | 128 -------
.../http/TestHttpNotificationServiceSSL.java | 252 ------------
nifi-bootstrap/src/test/resources/keystore.jks | Bin 3088 -> 0 bytes
nifi-bootstrap/src/test/resources/truststore.jks | Bin 911 -> 0 bytes
.../serialization/record/util/DataTypeUtils.java | 7 +
.../apache/nifi/stream/io/LimitingInputStream.java | 7 +
nifi-commons/nifi-web-utils/pom.xml | 2 +-
.../controller/repository/ContentRepository.java | 18 +
.../org/apache/nifi/util/MockSessionFactory.java | 2 +-
.../accumulo/processors/PutAccumuloRecord.java | 3 +-
.../apache/nifi/amqp/processors/AMQPConsumer.java | 10 +
.../nifi/amqp/processors/AMQPConsumerTest.java | 17 +
.../apache/nifi/amqp/processors/TestChannel.java | 6 +-
.../azure/storage/PutAzureDataLakeStorage.java | 13 +-
.../additionalDetails.html | 57 +++
.../azure/storage/ITPutAzureDataLakeStorage.java | 17 +
.../nifi-cdc-mysql-processors/pom.xml | 14 +-
.../cdc/mysql/processors/CaptureChangeMySQL.java | 150 ++++++--
.../processors/ssl/BinaryLogSSLSocketFactory.java | 56 +++
.../apache/nifi/cdc/mysql/MockBinlogClient.groovy | 8 +
.../mysql/processors/CaptureChangeMySQLTest.groovy | 63 ++-
.../ssl/BinaryLogSSLSocketFactoryTest.java | 67 ++++
.../nifi-elasticsearch-processors/pom.xml | 2 +-
.../java/org/apache/nifi/util/db/JdbcCommon.java | 13 +-
.../main/java/org/apache/nifi/csv/CSVUtils.java | 41 +-
.../java/org/apache/nifi/csv/CSVUtilsTest.java | 23 +-
.../nifi-framework/nifi-framework-cluster/pom.xml | 2 +-
.../okhttp/OkHttpReplicationClientTest.groovy | 4 -
.../repository/StandardProcessSession.java | 47 ++-
.../repository/io/ContentClaimInputStream.java | 10 +-
.../apache/nifi/groups/StandardProcessGroup.java | 2 +
.../repository/FileSystemRepository.java | 16 +
.../repository/VolatileContentRepository.java | 5 +
.../crypto/EncryptedFileSystemRepository.java | 26 +-
.../EncryptedFileSystemRepositoryTest.groovy | 2 +-
.../repository/StandardProcessSessionIT.java | 21 +
.../org/apache/nifi/web/api/AccessResource.java | 6 +-
.../web/search/query/RegexSearchQueryParser.java | 4 +-
.../search/query/RegexSearchQueryParserTest.java | 13 +-
.../impl/StandardSAMLConfigurationFactory.java | 8 +
.../repository/ByteArrayContentRepository.java | 14 +
.../nifi/processors/hadoop/GetHDFSFileInfo.java | 424 +++++++++++----------
.../nifi-kudu-controller-service/pom.xml | 5 -
.../nifi-kudu-bundle/nifi-kudu-processors/pom.xml | 4 -
nifi-nar-bundles/nifi-kudu-bundle/pom.xml | 5 +
.../provenance/EncryptedSchemaRecordWriter.java | 133 +------
.../EncryptedWriteAheadProvenanceRepository.java | 12 +-
.../provenance/EventIdFirstSchemaRecordWriter.java | 232 ++++-------
.../provenance/WriteAheadProvenanceRepository.java | 2 +
.../serialization/CompressableRecordWriter.java | 19 +-
.../provenance/serialization/RecordReaders.java | 23 +-
.../provenance/serialization/RecordWriter.java | 19 +-
.../provenance/store/WriteAheadStorePartition.java | 10 +-
.../provenance/util/ByteArrayDataOutputStream.java | 39 --
.../util/ByteArrayDataOutputStreamCache.java | 52 ---
.../EncryptedSchemaRecordReaderWriterTest.groovy | 6 +-
.../provenance/AbstractTestRecordReaderWriter.java | 44 ++-
.../TestEventIdFirstSchemaRecordReaderWriter.java | 48 +--
.../controller/livy/LivySessionController.java | 2 -
.../processors/standard/AbstractExecuteSQL.java | 3 +-
.../processors/standard/GenerateTableFetch.java | 3 +
.../apache/nifi/processors/standard/ListFTP.java | 1 +
.../processors/standard/PutDatabaseRecord.java | 11 +-
.../org/apache/nifi/processors/standard/Wait.java | 39 +-
.../nifi/processors/standard/util/FTPTransfer.java | 1 +
.../additionalDetails.html | 110 +++++-
.../standard/TestPutDatabaseRecord.groovy | 44 ++-
.../processors/standard/TestExecuteSQLRecord.java | 43 +++
.../standard/TestGenerateTableFetch.java | 12 +
.../org/apache/nifi/controller/MonitorMemory.java | 23 +-
nifi-nar-bundles/nifi-standard-bundle/pom.xml | 2 +-
.../nifi-lookup-services/pom.xml | 2 +-
.../nifi-oauth2-provider-service/pom.xml | 2 +-
.../main/java/org/apache/nifi/csv/CSVReader.java | 15 +-
.../apache/nifi/csv/JacksonCSVRecordReader.java | 15 +
.../nifi/csv/TestCSVHeaderSchemaStrategy.java | 30 +-
.../org/apache/nifi/csv/TestCSVRecordReader.java | 77 +++-
.../nifi/csv/TestJacksonCSVRecordReader.java | 57 ++-
nifi-toolkit/nifi-toolkit-api/pom.xml | 6 +-
pom.xml | 1 +
85 files changed, 1764 insertions(+), 1317 deletions(-)
create mode 100644
nifi-bootstrap/src/test/java/org/apache/nifi/bootstrap/http/HttpNotificationServiceTest.java
delete mode 100644
nifi-bootstrap/src/test/java/org/apache/nifi/bootstrap/http/TestHttpNotificationService.java
delete mode 100644
nifi-bootstrap/src/test/java/org/apache/nifi/bootstrap/http/TestHttpNotificationServiceCommon.java
delete mode 100644
nifi-bootstrap/src/test/java/org/apache/nifi/bootstrap/http/TestHttpNotificationServiceSSL.java
delete mode 100644 nifi-bootstrap/src/test/resources/keystore.jks
delete mode 100644 nifi-bootstrap/src/test/resources/truststore.jks
create mode 100644
nifi-nar-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/resources/docs/org.apache.nifi.processors.azure.storage.PutAzureDataLakeStorage/additionalDetails.html
create mode 100644
nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/main/java/org/apache/nifi/cdc/mysql/processors/ssl/BinaryLogSSLSocketFactory.java
create mode 100644
nifi-nar-bundles/nifi-cdc/nifi-cdc-mysql-bundle/nifi-cdc-mysql-processors/src/test/java/org/apache/nifi/cdc/mysql/processors/ssl/BinaryLogSSLSocketFactoryTest.java
delete mode 100644
nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/util/ByteArrayDataOutputStream.java
delete mode 100644
nifi-nar-bundles/nifi-provenance-repository-bundle/nifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/util/ByteArrayDataOutputStreamCache.java
