Repository: nifi Updated Branches: refs/heads/master 6518778c1 -> 390754c57
NIFI-3179 Added support for default UTF-8 char encoding removed deprected usage of BAOS and BAIS This closes #1452. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/390754c5 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/390754c5 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/390754c5 Branch: refs/heads/master Commit: 390754c5754f821e66d519a269cd0ee56f5e3622 Parents: 6518778 Author: Oleg Zhurakousky <[email protected]> Authored: Sun Jan 29 10:11:09 2017 -0500 Committer: Pierre Villard <[email protected]> Committed: Tue Jan 31 15:33:20 2017 +0100 ---------------------------------------------------------------------- .../apache/nifi/processors/standard/MergeContent.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/390754c5/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeContent.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeContent.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeContent.java index f18416e..1c77cbd 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeContent.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/MergeContent.java @@ -16,9 +16,12 @@ */ package org.apache.nifi.processors.standard; +import java.io.BufferedInputStream; +import java.io.BufferedOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; +import java.nio.charset.StandardCharsets; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; @@ -78,8 +81,6 @@ import org.apache.nifi.processor.util.StandardValidators; import org.apache.nifi.processor.util.bin.Bin; import org.apache.nifi.processor.util.bin.BinFiles; import org.apache.nifi.processor.util.bin.BinManager; -import org.apache.nifi.stream.io.BufferedInputStream; -import org.apache.nifi.stream.io.BufferedOutputStream; import org.apache.nifi.stream.io.NonCloseableOutputStream; import org.apache.nifi.stream.io.StreamUtils; import org.apache.nifi.util.FlowFilePackager; @@ -621,11 +622,11 @@ public class MergeContent extends BinFiles { byte[] property = null; final String descriptorValue = context.getProperty(descriptor).evaluateAttributeExpressions().getValue(); if (descriptorValue != null && flowFiles != null && flowFiles.size() > 0) { - final String content = new String(readContent(descriptorValue)); + final String content = new String(readContent(descriptorValue), StandardCharsets.UTF_8); final FlowFile flowFile = flowFiles.get(0); if (flowFile != null && content != null) { final PropertyValue propVal = context.newPropertyValue(content).evaluateAttributeExpressions(flowFile); - property = propVal.getValue().getBytes(); + property = propVal.getValue().getBytes(StandardCharsets.UTF_8); } } return property; @@ -639,7 +640,7 @@ public class MergeContent extends BinFiles { if (flowFile != null) { final String value = context.getProperty(descriptor).evaluateAttributeExpressions(flowFile).getValue(); if (value != null) { - property = value.getBytes(); + property = value.getBytes(StandardCharsets.UTF_8); } } } @@ -780,7 +781,6 @@ public class MergeContent extends BinFiles { if (attributes.containsKey(CoreAttributes.MIME_TYPE.key())) { attributes.put("content-type", attributes.get(CoreAttributes.MIME_TYPE.key())); } - packager.packageFlowFile(in, out, attributes, flowFile.getSize()); } }
