rya-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ly, Kiet" <Kiet...@finra.org>
Subject Re: InterruptedException
Date Thu, 19 Jan 2017 16:13:24 GMT
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.mihalik@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.mihalik@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.Ly@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.
    >
    >
    

Mime
View raw message