Repository: nifi Updated Branches: refs/heads/master b7dc21bd9 -> a2d3d0c28
Update to support offsets larger than 2 gigabyte. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/a2d3d0c2 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/a2d3d0c2 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/a2d3d0c2 Branch: refs/heads/master Commit: a2d3d0c2890b8a5a3433017b3077c704583b1277 Parents: b7dc21b Author: Joe Skora <[email protected]> Authored: Fri Aug 19 15:49:11 2016 -0400 Committer: Mark Payne <[email protected]> Committed: Mon Aug 22 11:02:48 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/ModifyBytes.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/a2d3d0c2/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java index f0942af..444a172 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ModifyBytes.java @@ -114,10 +114,10 @@ public class ModifyBytes extends AbstractProcessor { final ComponentLog logger = getLogger(); - final int startOffset = context.getProperty(START_OFFSET).asDataSize(DataUnit.B).intValue(); - final int endOffset = context.getProperty(END_OFFSET).asDataSize(DataUnit.B).intValue(); + final long startOffset = context.getProperty(START_OFFSET).asDataSize(DataUnit.B).longValue(); + final long endOffset = context.getProperty(END_OFFSET).asDataSize(DataUnit.B).longValue(); final boolean removeAll = context.getProperty(REMOVE_ALL).asBoolean(); - final int newFileSize = removeAll ? 0 : (int) ff.getSize() - startOffset - endOffset; + final long newFileSize = removeAll ? 0L : ff.getSize() - startOffset - endOffset; final StopWatch stopWatch = new StopWatch(true); if (newFileSize <= 0) {
