You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by pv...@apache.org on 2017/01/31 14:33:54 UTC
nifi git commit: NIFI-3179 Added support for default UTF-8 char
encoding removed deprected usage of BAOS and BAIS
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 <ol...@suitcase.io>
Authored: Sun Jan 29 10:11:09 2017 -0500
Committer: Pierre Villard <pi...@gmail.com>
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());
}
}