Repository: nifi Updated Branches: refs/heads/master e5925ff4b -> 63a0d0c21
NIFI-1732 set jetty timeout to Long.MAX_VALUE This closes #337 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/63a0d0c2 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/63a0d0c2 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/63a0d0c2 Branch: refs/heads/master Commit: 63a0d0c211be8038905752a162732eef8ad1c436 Parents: e5925ff Author: Pierre Villard <[email protected]> Authored: Fri Apr 8 12:04:39 2016 +0200 Committer: jpercivall <[email protected]> Committed: Fri May 6 19:38:52 2016 -0400 ---------------------------------------------------------------------- .../java/org/apache/nifi/processors/standard/HandleHttpRequest.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/63a0d0c2/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java index 17b6550..b0e91b4 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/HandleHttpRequest.java @@ -389,6 +389,7 @@ public class HandleHttpRequest extends AbstractProcessor { // Right now, that information, though, is only in the ProcessSession, not the ProcessContext, // so it is not known to us. Should see if it can be added to the ProcessContext. final AsyncContext async = baseRequest.startAsync(); + async.setTimeout(Long.MAX_VALUE); // timeout is handled by HttpContextMap final boolean added = containerQueue.offer(new HttpRequestContainer(request, response, async)); if (added) {
