Sounds like a good PR :) But I think the idea was that the server should control the timeout value, not the client. Can we set the timeout value via the spring configs?
On Thu, Jan 19, 2017 at 11:14 AM Ly, Kiet <kiet...@finra.org> wrote: > That was fast replied, thanks. It would be nice if I can set parameter > when sending query, for instance, 1 hour time as > ‘query.infer=false&query.timeout=3600’ > > On 1/19/17, 11:08 AM, "Aaron D. Mihalik" <aaron.miha...@gmail.com> wrote: > > Note that the link was supposed to be to line #86 of > RdfController.java. > For some reason, by email client is pointing to line #8. > > On Thu, Jan 19, 2017 at 11:06 AM Aaron D. Mihalik < > aaron.miha...@gmail.com> > wrote: > > > It looks like there is a hard coded 2-minute timeout [1]. > > > > > > [1] > > > https://github.com/apache/incubator-rya/blob/master/web/web.rya/src/main/java/org/apache/cloud/rdf/web/sail/RdfController.java#L8 > > 6 > > > > On Thu, Jan 19, 2017 at 11:01 AM Ly, Kiet <kiet...@finra.org> wrote: > > > > I got interrupted exception during query. Is it timing out? Is there > a > > parameter setting for query timeout? Thanks. > > > > root cause > > java.lang.InterruptedException > > > > > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) > > > > > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088) > > > > > java.util.concurrent.ArrayBlockingQueue.poll(ArrayBlockingQueue.java:418) > > > > > org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.hasNext(TabletServerBatchReaderIterator.java:202) > > > > > org.apache.rya.accumulo.query.RyaStatementBindingSetKeyValueIterator.hasNext(RyaStatementBindingSetKeyValueIterator.java:96) > > > > > org.apache.rya.api.persist.utils.RyaDAOHelper$2.hasNext(RyaDAOHelper.java:142) > > > > > info.aduna.iteration.ConvertingIteration.hasNext(ConvertingIteration.java:73) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.getNextElement(MultipleBindingSetsIterator.java:84) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.getNextElement(MultipleBindingSetsIterator.java:36) > > > > > info.aduna.iteration.LookAheadIteration.lookAhead(LookAheadIteration.java:91) > > > > > info.aduna.iteration.LookAheadIteration.hasNext(LookAheadIteration.java:60) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.initIter(MultipleBindingSetsIterator.java:65) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.<init>(MultipleBindingSetsIterator.java:50) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:110) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:756) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:200) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:256) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.<init>(MultipleBindingSetsIterator.java:48) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:110) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:756) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:200) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:256) > > > > > org.apache.rya.rdftriplestore.evaluation.MultipleBindingSetsIterator.<init>(MultipleBindingSetsIterator.java:48) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:110) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:756) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:200) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:256) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:662) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:577) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:197) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:256) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:607) > > > > > org.openrdf.query.algebra.evaluation.impl.EvaluationStrategyImpl.evaluate(EvaluationStrategyImpl.java:197) > > > > > org.apache.rya.rdftriplestore.evaluation.ParallelEvaluationStrategyImpl.evaluate(ParallelEvaluationStrategyImpl.java:256) > > > > > org.apache.rya.rdftriplestore.RdfCloudTripleStoreConnection.evaluateInternal(RdfCloudTripleStoreConnection.java:393) > > > > > org.openrdf.sail.helpers.SailConnectionBase.evaluate(SailConnectionBase.java:295) > > > > > org.openrdf.repository.sail.SailTupleQuery.evaluate(SailTupleQuery.java:60) > > > > > org.openrdf.repository.sail.SailTupleQuery.evaluate(SailTupleQuery.java:75) > > > > > org.apache.cloud.rdf.web.sail.RdfController.performQuery(RdfController.java:211) > > > > > org.apache.cloud.rdf.web.sail.RdfController.queryRdf(RdfController.java:151) > > sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > > > > > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) > > > > > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) > > java.lang.reflect.Method.invoke(Method.java:498) > > > > > org.springframework.web.bind.annotation.support.HandlerMethodInvoker.invokeHandlerMethod(HandlerMethodInvoker.java:176) > > > > > org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter.invokeHandlerMethod(AnnotationMethodHandlerAdapter.java:440) > > > > > org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter.handle(AnnotationMethodHandlerAdapter.java:428) > > > > > org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:933) > > > > > org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:867) > > > > > org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:953) > > > > > org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:844) > > javax.servlet.http.HttpServlet.service(HttpServlet.java:622) > > > > > org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:829) > > javax.servlet.http.HttpServlet.service(HttpServlet.java:729) > > > > > org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52) > > > > Confidentiality Notice:: This email, including attachments, may > include > > non-public, proprietary, confidential or legally privileged > information. > > If you are not an intended recipient or an authorized agent of an > intended > > recipient, you are hereby notified that any dissemination, > distribution or > > copying of the information contained in or transmitted with this > e-mail is > > unauthorized and strictly prohibited. If you have received this > email in > > error, please notify the sender by replying to this message and > permanently > > delete this e-mail, its attachments, and any copies of it > immediately. You > > should not retain, copy or use this e-mail or any attachment for any > > purpose, nor disclose all or any part of the contents to any other > person. > > Thank you. > > > > > > >
