This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 256de0fde0e NIFI-16292 Avoid forcing PathStyleAccess when endpoint
Override set for S3 (#11624)
256de0fde0e is described below
commit 256de0fde0e19282ea1d8b5c9e041305ef553f14
Author: Nicolas Chauvet (kwizart) <[email protected]>
AuthorDate: Sat Sep 5 00:32:33 2026 +0200
NIFI-16292 Avoid forcing PathStyleAccess when endpoint Override set for S3
(#11624)
- Added Path Style Access property to remaining S3 Processors
Signed-off-by: David Handermann <[email protected]>
---
.../java/org/apache/nifi/processors/aws/s3/AbstractS3Processor.java | 3 +--
.../src/main/java/org/apache/nifi/processors/aws/s3/CopyS3Object.java | 1 +
.../main/java/org/apache/nifi/processors/aws/s3/DeleteS3Object.java | 1 +
.../src/main/java/org/apache/nifi/processors/aws/s3/FetchS3Object.java | 1 +
.../java/org/apache/nifi/processors/aws/s3/GetS3ObjectMetadata.java | 1 +
.../main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectTags.java | 1 +
.../src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java | 1 +
.../src/main/java/org/apache/nifi/processors/aws/s3/TagS3Object.java | 1 +
8 files changed, 8 insertions(+), 2 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/s3/AbstractS3Processor.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/s3/AbstractS3Processor.java
index fcdb0104770..e1769db7af0 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/s3/AbstractS3Processor.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-abstract-processors/src/main/java/org/apache/nifi/processors/aws/s3/AbstractS3Processor.java
@@ -222,8 +222,7 @@ public abstract class AbstractS3Processor extends
AbstractAwsSyncProcessor<S3Cli
}
final Boolean usePathStyleAccess =
context.getProperty(USE_PATH_STYLE_ACCESS).asBoolean();
- final boolean endpointOverrideSet =
StringUtils.isNotBlank(context.getProperty(ENDPOINT_OVERRIDE).evaluateAttributeExpressions().getValue());
- if (usePathStyleAccess == Boolean.TRUE || endpointOverrideSet) {
+ if (usePathStyleAccess == Boolean.TRUE) {
configurationBuilder.pathStyleAccessEnabled(true);
}
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/CopyS3Object.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/CopyS3Object.java
index fd524e4e680..7d888e4ab80 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/CopyS3Object.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/CopyS3Object.java
@@ -101,6 +101,7 @@ public class CopyS3Object extends AbstractS3Processor {
CANNED_ACL,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE
);
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/DeleteS3Object.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/DeleteS3Object.java
index 5d7d7a5cd73..58554241927 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/DeleteS3Object.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/DeleteS3Object.java
@@ -74,6 +74,7 @@ public class DeleteS3Object extends AbstractS3Processor {
VERSION_ID,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE
);
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/FetchS3Object.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/FetchS3Object.java
index 159dae85681..1960dd218de 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/FetchS3Object.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/FetchS3Object.java
@@ -280,6 +280,7 @@ public class FetchS3Object extends AbstractS3Processor {
VERSION_ID,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
ENCRYPTION_SERVICE,
PROXY_CONFIGURATION_SERVICE,
REQUESTER_PAYS,
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectMetadata.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectMetadata.java
index a1879fac1b9..ebf198e2b14 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectMetadata.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectMetadata.java
@@ -96,6 +96,7 @@ public class GetS3ObjectMetadata extends AbstractS3Processor {
TIMEOUT,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE
);
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectTags.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectTags.java
index f5b84a6536a..cc89659f8d5 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectTags.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/GetS3ObjectTags.java
@@ -94,6 +94,7 @@ public class GetS3ObjectTags extends AbstractS3Processor {
TIMEOUT,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE
);
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
index 429e8cdc091..8f7a08f1f5f 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
@@ -304,6 +304,7 @@ public class ListS3 extends AbstractS3Processor implements
VerifiableProcessor,
TIMEOUT,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE,
DELIMITER,
PREFIX,
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/TagS3Object.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/TagS3Object.java
index 88845173fa5..fd8ed99f006 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/TagS3Object.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/TagS3Object.java
@@ -112,6 +112,7 @@ public class TagS3Object extends AbstractS3Processor {
TIMEOUT,
SSL_CONTEXT_SERVICE,
ENDPOINT_OVERRIDE,
+ USE_PATH_STYLE_ACCESS,
PROXY_CONFIGURATION_SERVICE
);
