Mailing-List: contact dev-help@atlas.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@atlas.apache.org
Date: Mon, 18 Dec 2017 15:15:00 +0000 (UTC)
From: =?utf-8?Q?P=C3=A9ter_Gerg=C5=91_Barna_=28JIRA=29?= <jira@apache.org>
To: dev@atlas.apache.org
Message-ID: <JIRA.13125564.1513588044000.483186.1513610100351@Atlassian.JIRA>
In-Reply-To: <JIRA.13125564.1513588044000@Atlassian.JIRA>
References: <JIRA.13125564.1513588044000@Atlassian.JIRA> <JIRA.13125564.1513588044222@jira-lw-us.apache.org>
Subject: [jira] [Commented] (ATLAS-2313) Error: Gremlin script execution
 failed: g.V().has('__typeName', 'Column').limit(25).toList()
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable
archived-at: Mon, 18 Dec 2017 15:15:09 -0000


    [ https://issues.apache.org/jira/browse/ATLAS-2313?page=3Dcom.atlassian=
.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=3D1629=
5107#comment-16295107 ]=20

P=C3=A9ter Gerg=C5=91 Barna commented on ATLAS-2313:
------------------------------------------

[~grahamwallis], thanks for your comment. Indeed, Titan Gremlin does not co=
ntain 'limit()'  http://s3.thinkaurelius.com/docs/titan/0.5.4/gremlin.html

I went through the code from DiscoveryREST.searchUsingDSL to the end of Ent=
ityDiscoveryService.searchUsingDslQuery, trying to locate the point where i=
t should be decided which type of Gremlin to be used.=20

It looks to me, it would be in the  EntityDiscoveryService.toGremlinQuery m=
ethod or more like in the QueryProcessor class.
I haven't found an enum like GremlinClause that would be compatible with Ti=
tan Gremlin.=20
It looks to me that this problem was introduced with https://issues.apache.=
org/jira/browse/ATLAS-2229

cc [~ashutoshm] [~madhan.neethiraj]

> Error: Gremlin script execution failed: g.V().has('__typeName', 'Column')=
.limit(25).toList()
> -------------------------------------------------------------------------=
-------------------
>
>                 Key: ATLAS-2313
>                 URL: https://issues.apache.org/jira/browse/ATLAS-2313
>             Project: Atlas
>          Issue Type: Bug
>          Components:  atlas-core
>    Affects Versions: 1.0.0
>            Reporter: P=C3=A9ter Gerg=C5=91 Barna
>
> Repro steps:
> - build latest atlas form source (with titan as graph provider)
> {noformat}
> mvn clean -DskipTests -DGRAPH_PROVIDER=3Dtitan0 install -Pdist,embedded-h=
base-solr,graph-provider-titan0
> {noformat}
> - start Atlas with empty Solar, Hbase, Zookeeper (that is, before startin=
g Atlas, delete and recreate Solr collections, delete Hbase database, delet=
e Atlas related nodes from Zookeeper)
> - run quicstart.py in order to generate some test data
> - on the Basic search UI, choose Search by type =3D "Column" and click se=
arch
> - from the results, in the firts row, click on "Column"=20
> Then you will get this error on the UI:
> Error: Gremlin script execution failed: g.V().has('__typeName', 'Column')=
.limit(25).toList()
> This will be in the logs:
> {noformat}
> 2017-12-18 10:01:12,998 DEBUG - [pool-1-thread-1:] ~ Access is allowed so=
 forwarding the request!!! (AtlasAuthorizationFilter:155)
> 2017-12-18 10:01:12,998 DEBUG - [pool-1-thread-1:] ~ /api/atlas/v2/search=
/dsl?limit=3D25&offset=3D0&query=3DColumn&_=3D1513587272660 reached end of =
additional filter chain; proceeding with original chain (Filt
> erChainProxy$VirtualFilterChain:310)
> 2017-12-18 10:01:12,998 DEBUG - [pool-1-thread-1:] ~ call filter AuditFil=
ter (ServletHandler$CachedChain:1680)
> 2017-12-18 10:01:12,998 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ call servlet jersey-servlet@1d89cbe8=3D=3Dcom.sun.jersey=
.spi.spring.container.servlet.SpringServlet,1,true (Servl
> etHandler$CachedChain:1711)
> 2017-12-18 10:01:12,999 INFO  - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ GraphTransaction intercept for org.apache.atlas.discover=
y.EntityDiscoveryService.searchUsingDslQuery (GraphTr
> ansactionAdvisor$1:41)
> 2017-12-18 10:01:13,071 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ addFrom(typeName=3DColumn) (QueryProcessor:82)
> 2017-12-18 10:01:13,072 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ getText() =3D> g.V().has('__typeName', 'Column').limit(2=
5).toList() (QueryProcessor:251)
> 2017-12-18 10:01:13,072 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ Translated Gremlin Query: g.V().has('__typeName', 'Colum=
n').limit(25).toList() (EntityDiscoveryService:693)
> 2017-12-18 10:01:13,072 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ Executing DSL query: Column (EntityDiscoveryService:132)
> 2017-12-18 10:01:13,167 DEBUG - [SyncThread:0:] ~ Processing request:: se=
ssionid:0x16068d49b730000 type:ping cxid:0xfffffffffffffffe zxid:0xffffffff=
fffffffe txntype:unknown reqpath:n/a (FinalRequestPro
> cessor:88)
> 2017-12-18 10:01:13,167 DEBUG - [SyncThread:0:] ~ sessionid:0x16068d49b73=
0000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unkn=
own reqpath:n/a (FinalRequestProcessor:160)
> 2017-12-18 10:01:13,167 DEBUG - [main-SendThread(localhost:9026):] ~ Got =
ping response for sessionid: 0x16068d49b730000 after 0ms (ClientCnxn$SendTh=
read:717)
> 2017-12-18 10:01:13,344 DEBUG - [kafka-network-thread-1-PLAINTEXT-0:] ~ C=
ompleted request:Name: FetchRequest; Version: 2; CorrelationId: 984; Client=
Id: consumer-1; ReplicaId: -1; MaxWait: 500 ms; MinBy
> tes: 1 bytes from connection 127.0.0.1:9027-127.0.0.1:49773;totalTime:501=
,requestQueueTime:0,localTime:0,remoteTime:501,responseQueueTime:0,sendTime=
:0,securityProtocol:PLAINTEXT,principal:User:ANONYMOU
> S (RequestChannel$Request:158)
> 2017-12-18 10:01:13,502 DEBUG - [SyncThread:0:] ~ Processing request:: se=
ssionid:0x16068d49b730000 type:ping cxid:0xfffffffffffffffe zxid:0xffffffff=
fffffffe txntype:unknown reqpath:n/a (FinalRequestPro
> cessor:88)
> 2017-12-18 10:01:13,502 DEBUG - [SyncThread:0:] ~ sessionid:0x16068d49b73=
0000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unkn=
own reqpath:n/a (FinalRequestProcessor:160)
> 2017-12-18 10:01:13,502 DEBUG - [main-SendThread(localhost:9026):] ~ Got =
ping response for sessionid: 0x16068d49b730000 after 0ms (ClientCnxn$SendTh=
read:717)
> 2017-12-18 10:01:13,836 DEBUG - [SyncThread:0:] ~ Processing request:: se=
ssionid:0x16068d49b730000 type:ping cxid:0xfffffffffffffffe zxid:0xffffffff=
fffffffe txntype:unknown reqpath:n/a (FinalRequestPro
> cessor:88)
> 2017-12-18 10:01:13,836 DEBUG - [SyncThread:0:] ~ sessionid:0x16068d49b73=
0000 type:ping cxid:0xfffffffffffffffe zxid:0xfffffffffffffffe txntype:unkn=
own reqpath:n/a (FinalRequestProcessor:160)
> 2017-12-18 10:01:13,836 DEBUG - [main-SendThread(localhost:9026):] ~ Got =
ping response for sessionid: 0x16068d49b730000 after 0ms (ClientCnxn$SendTh=
read:717)
> 2017-12-18 10:01:13,845 DEBUG - [kafka-network-thread-1-PLAINTEXT-0:] ~ C=
ompleted request:Name: FetchRequest; Version: 2; CorrelationId: 985; Client=
Id: consumer-1; ReplicaId: -1; MaxWait: 500 ms; MinBy
> tes: 1 bytes from connection 127.0.0.1:9027-127.0.0.1:49773;totalTime:501=
,requestQueueTime:0,localTime:0,remoteTime:500,responseQueueTime:0,sendTime=
:1,securityProtocol:PLAINTEXT,principal:User:ANONYMOU
> S (RequestChannel$Request:158)
> 2017-12-18 10:01:13,906 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ <=3D=3D AtlasErrorCode.getMessage([g.V().has('__typeName=
', 'Column').limit(25).toList()]) (AtlasErrorCode:168)
> 2017-12-18 10:01:13,906 DEBUG - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ =3D=3D> AtlasErrorCode.getMessage([g.V().has('__typeName=
', 'Column').limit(25).toList()]): Gremlin script executi
> on failed: g.V().has('__typeName', 'Column').limit(25).toList() (AtlasErr=
orCode:175)
> 2017-12-18 10:01:13,906 ERROR - [pool-1-thread-1 - 79f55cd2-99a1-4804-a61=
2-793ede7cea79:] ~ graph rollback due to exception  (GraphTransactionInterc=
eptor:71)
> org.apache.atlas.exception.AtlasBaseException: Gremlin script execution f=
ailed: g.V().has('__typeName', 'Column').limit(25).toList()
>         at org.apache.atlas.repository.graphdb.titan0.Titan0Graph.execute=
GremlinScript(Titan0Graph.java:342)
>         at org.apache.atlas.repository.graphdb.titan0.Titan0Graph.execute=
GremlinScript(Titan0Graph.java:274)
>         at org.apache.atlas.discovery.EntityDiscoveryService.searchUsingD=
slQuery(EntityDiscoveryService.java:135)
>         at org.apache.atlas.discovery.EntityDiscoveryService$$FastClassBy=
SpringCGLIB$$1af2cf1f.invoke(<generated>)
>         at org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy=
.java:204)
>         at org.springframework.aop.framework.CglibAopProxy$CglibMethodInv=
ocation.invokeJoinpoint(CglibAopProxy.java:738)
>         at org.springframework.aop.framework.ReflectiveMethodInvocation.p=
roceed(ReflectiveMethodInvocation.java:157)
>         at org.apache.atlas.GraphTransactionInterceptor.invoke(GraphTrans=
actionInterceptor.java:60)
>         at org.springframework.aop.framework.ReflectiveMethodInvocation.p=
roceed(ReflectiveMethodInvocation.java:179)
>         at org.springframework.aop.framework.CglibAopProxy$DynamicAdvised=
Interceptor.intercept(CglibAopProxy.java:673)
>         at org.apache.atlas.discovery.EntityDiscoveryService$$EnhancerByS=
pringCGLIB$$269c51a6.searchUsingDslQuery(<generated>)
>         at org.apache.atlas.web.rest.DiscoveryREST.searchUsingDSL(Discove=
ryREST.java:115)
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>         at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccess=
orImpl.java:62)
>         at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMeth=
odAccessorImpl.java:43)
>         at java.lang.reflect.Method.invoke(Method.java:498)
>         at com.sun.jersey.spi.container.JavaMethodInvokerFactory$1.invoke=
(JavaMethodInvokerFactory.java:60)
>         at com.sun.jersey.server.impl.model.method.dispatch.AbstractResou=
rceMethodDispatchProvider$TypeOutInvoker._dispatch(AbstractResourceMethodDi=
spatchProvider.java:185)
>         at com.sun.jersey.server.impl.model.method.dispatch.ResourceJavaM=
ethodDispatcher.dispatch(ResourceJavaMethodDispatcher.java:75)
>         at com.sun.jersey.server.impl.uri.rules.HttpMethodRule.accept(Htt=
pMethodRule.java:302)
>         at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(=
RightHandPathRule.java:147)
>         at com.sun.jersey.server.impl.uri.rules.ResourceClassRule.accept(=
ResourceClassRule.java:108)
>         at com.sun.jersey.server.impl.uri.rules.RightHandPathRule.accept(=
RightHandPathRule.java:147)
>         at com.sun.jersey.server.impl.uri.rules.RootResourceClassesRule.a=
ccept(RootResourceClassesRule.java:84)
>         at com.sun.jersey.server.impl.application.WebApplicationImpl._han=
dleRequest(WebApplicationImpl.java:1542)
>         at com.sun.jersey.server.impl.application.WebApplicationImpl._han=
dleRequest(WebApplicationImpl.java:1473)
>         at com.sun.jersey.server.impl.application.WebApplicationImpl.hand=
leRequest(WebApplicationImpl.java:1419)
>         at com.sun.jersey.server.impl.application.WebApplicationImpl.hand=
leRequest(WebApplicationImpl.java:1409)
>         at com.sun.jersey.spi.container.servlet.WebComponent.service(WebC=
omponent.java:409)
>         at com.sun.jersey.spi.container.servlet.ServletContainer.service(=
ServletContainer.java:558)
>         at com.sun.jersey.spi.container.servlet.ServletContainer.service(=
ServletContainer.java:733)
>         at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
>         at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.j=
ava:845)
> {noformat}


--
This message was sent by Atlassian JIRA
(v6.4.14#64029)