This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
from 4a784242b0 NIFI-14949 - Display bulletin stack trace on bulletin board
if it exists. Add the stack trace to the copied content if available. (#10343)
add 49778f23c3 NIFI-13192 Upgraded AWS S3 Processors and others to AWS SDK
2 (#10460)
No new revisions were added by this update.
Summary of changes:
.../nifi-aws-abstract-processors/pom.xml | 16 +-
.../AbstractAWSCredentialsProviderProcessor.java | 351 -------------
.../aws/{v2 => }/AbstractAwsAsyncProcessor.java | 36 +-
.../aws/{v2 => }/AbstractAwsProcessor.java | 94 ++--
.../aws/{v2 => }/AbstractAwsSyncProcessor.java | 41 +-
.../aws/{v2 => }/AwsHttpClientConfigurer.java | 2 +-
.../aws/dynamodb/AbstractDynamoDBProcessor.java | 2 +-
.../aws/kinesis/KinesisProcessorUtils.java | 2 +-
.../ml/AbstractAwsMachineLearningJobStarter.java | 35 +-
...stractAwsMachineLearningJobStatusProcessor.java | 13 +-
.../processors/aws/s3/AbstractS3Processor.java | 438 ++++++----------
.../processors/aws/s3/S3ClientBuilderWrapper.java | 153 ++++++
.../processors/aws/signer/AwsCustomSignerUtil.java | 53 --
.../nifi/processors/aws/signer/AwsSignerType.java | 74 ---
.../nifi/processors/aws/util/RegionUtilV1.java | 94 ----
.../aws/s3/S3ClientBuilderWrapperTest.java | 215 ++++++++
.../processors/aws/kinesis/ConsumeKinesis.java | 21 +-
.../processors/aws/kinesis/ConsumeKinesisIT.java | 3 +-
.../nifi-aws-bundle/nifi-aws-nar/pom.xml | 6 -
.../aws/AwsSecretsManagerParameterProvider.java | 12 +-
.../nifi-aws-bundle/nifi-aws-processors/pom.xml | 16 +-
.../aws/cloudwatch/PutCloudWatchMetric.java | 6 +-
.../provider/factory/CredentialsStrategy.java | 13 -
.../strategies/AbstractCredentialsStrategy.java | 10 -
.../AccessKeyPairCredentialsStrategy.java | 11 -
.../strategies/AnonymousCredentialsStrategy.java | 9 -
.../strategies/AssumeRoleCredentialsStrategy.java | 90 +---
.../ExplicitDefaultCredentialsStrategy.java | 7 -
.../strategies/FileCredentialsStrategy.java | 8 -
.../ImplicitDefaultCredentialsStrategy.java | 7 -
.../NamedProfileCredentialsStrategy.java | 8 -
.../AWSCredentialsProviderControllerService.java | 99 +---
.../processors/aws/dynamodb/DeleteDynamoDB.java | 4 +
.../nifi/processors/aws/dynamodb/GetDynamoDB.java | 4 +
.../nifi/processors/aws/dynamodb/PutDynamoDB.java | 4 +
.../processors/aws/dynamodb/PutDynamoDBRecord.java | 4 +
.../aws/kinesis/firehose/PutKinesisFirehose.java | 6 +-
.../aws/kinesis/stream/ConsumeKinesisStream.java | 13 +-
.../aws/kinesis/stream/PutKinesisStream.java | 6 +-
.../nifi/processors/aws/lambda/PutLambda.java | 6 +-
.../nifi/processors/aws/s3/CopyS3Object.java | 183 ++++---
.../nifi/processors/aws/s3/DeleteS3Object.java | 64 +--
.../nifi/processors/aws/s3/FetchS3Object.java | 182 ++++---
.../processors/aws/s3/GetS3ObjectMetadata.java | 133 +++--
.../nifi/processors/aws/s3/GetS3ObjectTags.java | 66 ++-
.../org/apache/nifi/processors/aws/s3/ListS3.java | 407 ++++++++-------
.../apache/nifi/processors/aws/s3/PutS3Object.java | 573 ++++++++++----------
.../apache/nifi/processors/aws/s3/TagS3Object.java | 79 +--
.../encryption/ClientSideCEncryptionStrategy.java | 45 +-
.../ClientSideKMSEncryptionStrategy.java | 42 +-
...ptionStrategy.java => S3EncryptionKeySpec.java} | 9 +-
.../aws/s3/encryption/S3EncryptionStrategy.java | 56 +-
.../encryption/ServerSideCEncryptionStrategy.java | 49 +-
.../ServerSideKMSEncryptionStrategy.java | 34 +-
.../encryption/ServerSideS3EncryptionStrategy.java | 15 +-
.../s3/encryption/StandardS3EncryptionService.java | 201 +++----
.../aws/s3/service/S3FileResourceService.java | 70 +--
.../nifi/processors/aws/s3/util/Expiration.java | 7 +-
.../apache/nifi/processors/aws/s3/util/S3Util.java | 134 +++++
.../org/apache/nifi/processors/aws/sns/PutSNS.java | 6 +-
.../apache/nifi/processors/aws/sqs/DeleteSQS.java | 6 +-
.../org/apache/nifi/processors/aws/sqs/GetSQS.java | 6 +-
.../org/apache/nifi/processors/aws/sqs/PutSQS.java | 6 +-
.../aws/cloudwatch/TestPutCloudWatchMetric.java | 5 +-
...WSCredentialsProviderControllerServiceTest.java | 49 +-
.../provider/service/MockAWSProcessor.java | 22 +-
...entialsProviderControllerServiceStrategies.java | 53 +-
.../aws/dynamodb/AbstractDynamoDBIT.java | 3 +-
.../aws/dynamodb/DeleteDynamoDBTest.java | 5 +-
.../processors/aws/dynamodb/GetDynamoDBTest.java | 3 +-
.../aws/dynamodb/PutDynamoDBRecordTest.java | 4 +-
.../processors/aws/dynamodb/PutDynamoDBTest.java | 3 +-
.../aws/kinesis/stream/ITConsumeKinesisStream.java | 4 -
.../kinesis/stream/TestConsumeKinesisStream.java | 7 +-
.../aws/ml/polly/GetAwsPollyStatusTest.java | 2 +-
.../aws/ml/polly/StartAwsPollyJobTest.java | 4 +-
.../ml/textract/GetAwsTextractJobStatusTest.java | 2 +-
.../ml/textract/StartAwsTextractJobStatusTest.java | 4 +-
.../transcribe/GetAwsTranscribeJobStatusTest.java | 2 +-
.../ml/transcribe/StartAwsTranscribeJobTest.java | 4 +-
.../ml/translate/GetAwsTranslateJobStatusTest.java | 2 +-
.../aws/ml/translate/StartAwsTranslateJobTest.java | 4 +-
.../nifi/processors/aws/s3/AbstractS3IT.java | 191 ++++---
.../nifi/processors/aws/s3/ITFetchS3Object.java | 7 +-
.../apache/nifi/processors/aws/s3/ITListS3.java | 6 +-
.../nifi/processors/aws/s3/ITPutS3Object.java | 262 +++-------
.../nifi/processors/aws/s3/ITTagS3Object.java | 22 +-
.../nifi/processors/aws/s3/TestCopyS3Object.java | 40 +-
.../nifi/processors/aws/s3/TestDeleteS3Object.java | 74 ++-
.../nifi/processors/aws/s3/TestFetchS3Object.java | 288 +++++-----
.../processors/aws/s3/TestGetS3ObjectMetadata.java | 94 ++--
.../processors/aws/s3/TestGetS3ObjectTags.java | 67 +--
.../apache/nifi/processors/aws/s3/TestListS3.java | 579 +++++++++++----------
.../nifi/processors/aws/s3/TestPutS3Object.java | 161 ++----
.../nifi/processors/aws/s3/TestTagS3Object.java | 146 +++---
.../aws/s3/encryption/S3EncryptionTestUtil.java | 34 +-
...ClientSideCEncryptionStrategyKeyValidation.java | 30 +-
.../s3/encryption/TestS3EncryptionStrategies.java | 264 ++++++----
...ServerSideCEncryptionStrategyKeyValidation.java | 22 +-
.../TestStandardS3EncryptionService.java | 90 ++--
.../TestStandardS3EncryptionServiceValidation.java | 109 ++--
.../aws/s3/service/S3FileResourceServiceTest.java | 58 +--
.../nifi/processors/aws/s3/util/S3UtilTest.java | 130 +++++
.../apache/nifi/processors/aws/sns/ITPutSNS.java | 5 +-
.../nifi/processors/aws/sqs/AbstractSQSIT.java | 5 +-
.../nifi/processors/aws/testutil/AuthUtils.java | 6 +-
.../nifi/processors/aws/region/RegionUtil.java | 122 +++++
.../nifi/processors/aws/region/RegionUtilV2.java | 59 ---
.../nifi/processors/aws/region/RegionUtilTest.java | 110 ++++
.../schemaregistry/AmazonGlueSchemaRegistry.java | 8 +-
.../nifi-aws-service-api-nar/pom.xml | 19 +
.../nifi-aws-bundle/nifi-aws-service-api/pom.xml | 15 +-
.../service/AWSCredentialsProviderService.java | 53 --
.../aws/s3/AmazonS3EncryptionService.java | 47 +-
nifi-extension-bundles/nifi-aws-bundle/pom.xml | 19 +
pom.xml | 25 +-
116 files changed, 3770 insertions(+), 3944 deletions(-)
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/AbstractAWSCredentialsProviderProcessor.java
rename
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/{v2
=> }/AbstractAwsAsyncProcessor.java (79%)
rename
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/{v2
=> }/AbstractAwsProcessor.java (84%)
rename
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/{v2
=> }/AbstractAwsSyncProcessor.java (73%)
rename
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/{v2
=> }/AwsHttpClientConfigurer.java (96%)
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/s3/S3ClientBuilderWrapper.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/signer/AwsCustomSignerUtil.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/signer/AwsSignerType.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/util/RegionUtilV1.java
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/test/java/org/apache/nifi/processors/aws/s3/S3ClientBuilderWrapperTest.java
copy
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/encryption/{NoOpEncryptionStrategy.java
=> S3EncryptionKeySpec.java} (69%)
copy
c2/c2-protocol/c2-protocol-api/src/main/java/org/apache/nifi/c2/protocol/api/ResourceType.java
=>
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/util/Expiration.java
(83%)
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/util/S3Util.java
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/test/java/org/apache/nifi/processors/aws/s3/util/S3UtilTest.java
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-regions/src/main/java/org/apache/nifi/processors/aws/region/RegionUtil.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-regions/src/main/java/org/apache/nifi/processors/aws/region/RegionUtilV2.java
create mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-regions/src/test/java/org/apache/nifi/processors/aws/region/RegionUtilTest.java
delete mode 100644
nifi-extension-bundles/nifi-aws-bundle/nifi-aws-service-api/src/main/java/org/apache/nifi/processors/aws/credentials/provider/service/AWSCredentialsProviderService.java
