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 7f5680d1fe NIFI-13002 Restored zstd Compression Level in
CompressContent
7f5680d1fe is described below
commit 7f5680d1fed374666ee92fd9e43c9d660507c467
Author: Joseph Witt <[email protected]>
AuthorDate: Thu Apr 4 11:19:54 2024 -0700
NIFI-13002 Restored zstd Compression Level in CompressContent
This closes #8604
Signed-off-by: David Handermann <[email protected]>
---
.../main/java/org/apache/nifi/processors/standard/CompressContent.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
index a910a4f875..1d95aebb9d 100644
---
a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
+++
b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CompressContent.java
@@ -349,7 +349,8 @@ public class CompressContent extends AbstractProcessor {
compressionOut = new
CompressorStreamFactory().createCompressorOutputStream(compressionFormat.toLowerCase(),
bufferedOut);
break;
case COMPRESSION_FORMAT_ZSTD:
- compressionOut = new
ZstdCompressorOutputStream(bufferedOut);
+ final int zstdCompressionLevel =
context.getProperty(COMPRESSION_LEVEL).asInteger() * 2;
+ compressionOut = new
ZstdCompressorOutputStream(bufferedOut, zstdCompressionLevel);
mimeTypeRef.set("application/zstd");
break;
case COMPRESSION_FORMAT_BROTLI: {
