Repository: nifi Updated Branches: refs/heads/master b2290b24a -> 1a91ecc37
NIFI-3352 - Address issue where ListenLumberjack was sending long numbers back to clients - instead of int This closes #1421. Signed-off-by: Andy LoPresto <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/1a91ecc3 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/1a91ecc3 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/1a91ecc3 Branch: refs/heads/master Commit: 1a91ecc379675912d03e5f2bda150eab0038e641 Parents: b2290b2 Author: Andre F de Miranda <[email protected]> Authored: Sat Jan 14 22:57:33 2017 +1100 Committer: Andy LoPresto <[email protected]> Committed: Mon Feb 13 23:55:21 2017 -0800 ---------------------------------------------------------------------- .../apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java | 2 +- .../nifi/processors/lumberjack/response/LumberjackResponse.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/1a91ecc3/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java index eec9022..9bc9468 100644 --- a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java +++ b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java @@ -161,7 +161,7 @@ public class LumberjackDecoder { // Lumberjack has a weird approach to frames, where compressed frames embed D(ata) or J(SON) frames. // inside a compressed input. - // Or astated in the documentation: + // Or as stated in the documentation: // // "As an example, you could have 3 data frames compressed into a single // 'compressed' frame type: 1D{k,v}{k,v}1D{k,v}{k,v}1D{k,v}{k,v}" http://git-wip-us.apache.org/repos/asf/nifi/blob/1a91ecc3/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java index 2ace367..850bba4 100644 --- a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java +++ b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java @@ -51,7 +51,7 @@ public class LumberjackResponse { return new LumberjackFrame.Builder() .version(version) .frameType(frameType) - .payload(ByteBuffer.allocate(8).putLong(seqNumber).array()) + .payload(ByteBuffer.allocate(4).putInt((int) seqNumber).array()) .build(); }
