Repository: nifi Updated Branches: refs/heads/master 274ed46d9 -> b2fae5f56
NIFI-5065: HTTP Site-to-Site fails sending data more than 2GB at once Int variables got overflown. This closes #5065 Signed-off-by: Mike Thomsen <mikerthom...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/b2fae5f5 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/b2fae5f5 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/b2fae5f5 Branch: refs/heads/master Commit: b2fae5f56ee13cba96d112d45b6a8f90af250317 Parents: 274ed46 Author: Koji Kawamura <ijokaruma...@apache.org> Authored: Tue Apr 10 17:15:30 2018 +0900 Committer: Mike Thomsen <mikerthom...@gmail.com> Committed: Tue Apr 10 16:08:11 2018 -0400 ---------------------------------------------------------------------- .../org/apache/nifi/remote/util/SiteToSiteRestApiClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/b2fae5f5/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/SiteToSiteRestApiClient.java ---------------------------------------------------------------------- diff --git a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/SiteToSiteRestApiClient.java b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/SiteToSiteRestApiClient.java index 1670a53..249325d 100644 --- a/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/SiteToSiteRestApiClient.java +++ b/nifi-commons/nifi-site-to-site-client/src/main/java/org/apache/nifi/remote/util/SiteToSiteRestApiClient.java @@ -773,8 +773,8 @@ public class SiteToSiteRestApiClient implements Closeable { private final ByteBuffer buffer = ByteBuffer.allocate(DATA_PACKET_CHANNEL_READ_BUFFER_SIZE); - private int totalRead = 0; - private int totalProduced = 0; + private long totalRead = 0; + private long totalProduced = 0; private boolean requestHasBeenReset = false;
