Apache
/
nifi
mirror of https://github.com/apache/nifi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "NIFI-3352 - Address issue where ListenLumberjack was sending long numbers back to clients - instead of int" 

This reverts commit 9609dafc34.
This commit is contained in:
Andre F de Miranda 2017-01-17 01:48:49 +11:00
parent 5b69c97f41
commit 8c7539b20a
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/frame/LumberjackDecoder.java
View File

@ -161,7 +161,7 @@ public class LumberjackDecoder {
// Lumberjack has a weird approach to frames, where compressed frames embed D(ata) or J(SON) frames. // Lumberjack has a weird approach to frames, where compressed frames embed D(ata) or J(SON) frames.
// inside a compressed input. // inside a compressed input.
// Or as stated in the documentation: // Or astated in the documentation:
// //
// "As an example, you could have 3 data frames compressed into a single // "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}" // 'compressed' frame type: 1D{k,v}{k,v}1D{k,v}{k,v}1D{k,v}{k,v}"

2
nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/src/main/java/org/apache/nifi/processors/lumberjack/response/LumberjackResponse.java
View File

@ -51,7 +51,7 @@ public class LumberjackResponse {
return new LumberjackFrame.Builder() return new LumberjackFrame.Builder()
.version(version) .version(version)
.frameType(frameType) .frameType(frameType)
.payload(ByteBuffer.allocate(4).putInt((int) seqNumber).array()) .payload(ByteBuffer.allocate(8).putLong(seqNumber).array())
.build(); .build();
} }