NIFI-335: Fixed bug that returned a byte instead of an int from CompressionInputStream.read(), which resulted in negative values getting returned when it should not have
Project: http://git-wip-us.apache.org/repos/asf/incubator-nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-nifi/commit/a00aade0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-nifi/tree/a00aade0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-nifi/diff/a00aade0 Branch: refs/heads/develop Commit: a00aade0e5b6f568104d207e38dbdc3d091416f5 Parents: 40e1fcb Author: Mark Payne <marka...@hotmail.com> Authored: Sun Feb 22 11:46:00 2015 -0500 Committer: Mark Payne <marka...@hotmail.com> Committed: Sun Feb 22 11:46:00 2015 -0500 ---------------------------------------------------------------------- .../java/org/apache/nifi/remote/io/CompressionInputStream.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-nifi/blob/a00aade0/nifi/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/CompressionInputStream.java ---------------------------------------------------------------------- diff --git a/nifi/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/CompressionInputStream.java b/nifi/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/CompressionInputStream.java index 71cf894..d953185 100644 --- a/nifi/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/CompressionInputStream.java +++ b/nifi/nifi-commons/nifi-utils/src/main/java/org/apache/nifi/remote/io/CompressionInputStream.java @@ -142,7 +142,7 @@ public class CompressionInputStream extends InputStream { return -1; } - return buffer[bufferIndex++]; + return buffer[bufferIndex++] & 0xFF; } @Override
