NIFI-2865: Fixed bug in StreamDemarcator that is exposed when the final bit of data in a stream is smaller than the previous and the previous demarcation ended on a buffer length boundary
This closes #1110. Signed-off-by: Bryan Bende <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9304df4d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9304df4d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9304df4d Branch: refs/heads/master Commit: 9304df4de060335526d29a77aa093db4004c8b2e Parents: b9cb6b1 Author: Mark Payne <[email protected]> Authored: Thu Oct 6 15:39:24 2016 -0400 Committer: Bryan Bende <[email protected]> Committed: Thu Oct 6 15:51:37 2016 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9304df4d/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java ---------------------------------------------------------------------- diff --git a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java index dc3d829..840bdb0 100644 --- a/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java +++ b/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/stream/io/util/StreamDemarcator.java @@ -145,6 +145,7 @@ public class StreamDemarcator implements Closeable { System.arraycopy(this.buffer, this.mark, this.buffer, 0, length); this.index = length; this.mark = 0; + this.readAheadLength = length; } }
