Repository: nifi Updated Branches: refs/heads/0.x 3e718262a -> 089fb0814
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/089fb081 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/089fb081 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/089fb081 Branch: refs/heads/0.x Commit: 089fb0814cf0a077314d97bbd922c37622f6a175 Parents: 3e71826 Author: Pierre Villard <[email protected]> Authored: Fri Apr 8 12:04:39 2016 +0200 Committer: jpercivall <[email protected]> Committed: Fri May 6 19:40:46 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/089fb081/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) {
