[jira] [Updated] (TINKERPOP-2133) Use neo4j index lookup in Neo4jGraphStep with HasContainers containing TextP predicates
[
https://issues.apache.org/jira/browse/TINKERPOP-2133?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrey Skorikov updated TINKERPOP-2133:
---
Summary: Use neo4j index lookup in Neo4jGraphStep with HasContainers
containing TextP predicates (was: Use neo4j indicex lookup in Neo4jGraphStep
with HasContainers containing TextP predicates)
> Use neo4j index lookup in Neo4jGraphStep with HasContainers containing TextP
> predicates
> ---
>
> Key: TINKERPOP-2133
> URL: https://issues.apache.org/jira/browse/TINKERPOP-2133
> Project: TinkerPop
> Issue Type: Improvement
> Components: neo4j
>Affects Versions: 3.4.0
>Reporter: Andrey Skorikov
>Priority: Major
> Labels: easyfix, performance
>
> When evaluating a Neo4jGraphStep with HasContainers containing TextP
> predicates, for example: g.V().has("Label", "name",
> TextP.containing("substring")), a scan over all vertices with the label is
> performed.
> Currently, an index lookup is used only when an complete property value is
> given, that is g.V().has("Label", "name", "exact") - implemented
> [here|https://github.com/apache/tinkerpop/blob/master/neo4j-gremlin/src/main/java/org/apache/tinkerpop/gremlin/neo4j/structure/trait/NoMultiNoMetaNeo4jTrait.java#L172].
> Allowing to use an index lookup for TextP predicates like containing,
> startingWith would substantially improve the evaluation performance.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Created] (TINKERPOP-2133) Use neo4j indicex lookup in Neo4jGraphStep with HasContainers containing TextP predicates
Andrey Skorikov created TINKERPOP-2133:
--
Summary: Use neo4j indicex lookup in Neo4jGraphStep with
HasContainers containing TextP predicates
Key: TINKERPOP-2133
URL: https://issues.apache.org/jira/browse/TINKERPOP-2133
Project: TinkerPop
Issue Type: Improvement
Components: neo4j
Affects Versions: 3.4.0
Reporter: Andrey Skorikov
When evaluating a Neo4jGraphStep with HasContainers containing TextP
predicates, for example: g.V().has("Label", "name",
TextP.containing("substring")), a scan over all vertices with the label is
performed.
Currently, an index lookup is used only when an complete property value is
given, that is g.V().has("Label", "name", "exact") - implemented
[here|https://github.com/apache/tinkerpop/blob/master/neo4j-gremlin/src/main/java/org/apache/tinkerpop/gremlin/neo4j/structure/trait/NoMultiNoMetaNeo4jTrait.java#L172].
Allowing to use an index lookup for TextP predicates like containing,
startingWith would substantially improve the evaluation performance.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Commented] (TINKERPOP-2019) Gremlin.Net.Driver.WebSocketConnection throws System.InvalidOperationException
[
https://issues.apache.org/jira/browse/TINKERPOP-2019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741245#comment-16741245
]
Florian Hockmann commented on TINKERPOP-2019:
-
We released [version 3.4.0|https://www.nuget.org/packages/Gremlin.Net/3.4.0]
this week which contains an improved connection pool and which now also
supports request pipelining. This means that a lot of the code in the driver
changed. (Those changes weren't yet in 3.4.0-rc2.) [~samimajed] could you
please try out whether the issue still happens with that version? Or could you
already fix this by upgrading to .NET Core 2.1?
> Gremlin.Net.Driver.WebSocketConnection throws System.InvalidOperationException
> --
>
> Key: TINKERPOP-2019
> URL: https://issues.apache.org/jira/browse/TINKERPOP-2019
> Project: TinkerPop
> Issue Type: Bug
> Components: dotnet
>Affects Versions: 3.3.3
> Environment: Azure App Service
>Reporter: Sami
>Priority: Critical
>
> We're getting the following {{System.InvalidOperationException}} error
> message:
> {code:c#}
> "There is already one outstanding 'SendAsync' call for this WebSocket
> instance. ReceiveAsync and SendAsync can be called simultaneously, but at
> most one outstanding operation for each of them is allowed at the same time.
> Problem Id:
> System.InvalidOperationException at
> Gremlin.Net.Driver.WebSocketConnection+d__5.MoveNext"{code}
>
> We get this exception sporadically and only a few times out of thousands.
> Unfortunately we have not been able to reproduce it.
>
> I understand that when dealing with web sockets, it is allowed to have only
> a single pending "send" or a single pending "receive".
>
> After looking at GitHub's WebSocketConnection class, I don't see any
> orchestration between SendMessageAsync's {{_client.SendAsync}} (currently
> line 54) and ReceiveMessageAsync's {{_client.ReceiveAsync}} (currently line
> 66).
>
> Reference Link:
>
> [https://github.com/apache/tinkerpop/blob/master/gremlin-dotnet/src/Gremlin.Net/Driver/WebSocketConnection.cs]
>
> I'm wondering if not having orchestration in the WebSocketConnection class
> to keep the single pending "send" or a single pending "receive" rule may be
> the cause.
>
> In our .NET Core web api application, we create the GremlinConnection as a
> singleton in Startup.cs and then have one central call that makes Gremlin
> calls; i.e. it's a very straightforward implementation.
>
> Startup.cs:
> {code:c#}
> public void ConfigureServices(IServiceCollection services)
> {
> //...other stuff removed for brevity
> services.AddSingleton();
> }{code}
>
> Reader.cs:
> {code:c#}
> public async Task> ExecuteGremlinQuery(string
> query)
> {
> try
> {
> return await _gremlinConnection.Client.SubmitAsync(query);
> }
> catch (Gremlin.Net.Driver.Exceptions.ResponseException responseException)
> {
> //our error handling removed for brevity!
> }
> }{code}
>
> We use the Gremlin.Net version 3.3.3 nuget package and the
> Microsoft.NETCore.App SDK
>
> Would it be possible to identify if this is indeed a bug on Gremlin.NET?
> And if it is, any thoughts on a best-practice (temporary) work-around that
> we can implement?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
[jira] [Commented] (TINKERPOP-2090) After running backend for a day or so System.IO.IOException keep throwing
[
https://issues.apache.org/jira/browse/TINKERPOP-2090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741244#comment-16741244
]
Florian Hockmann commented on TINKERPOP-2090:
-
[Version 3.4.0 was released|https://www.nuget.org/packages/Gremlin.Net/3.4.0] 4
days ago. [~saber], [~Zaoshi], [~Papapep], and [~SomeOneElse]: Could you try
that version out to see whether the problem still occurs with Gremlin.Net 3.4.0
(and then tell us here about the result)?
> After running backend for a day or so System.IO.IOException keep throwing
> -
>
> Key: TINKERPOP-2090
> URL: https://issues.apache.org/jira/browse/TINKERPOP-2090
> Project: TinkerPop
> Issue Type: Bug
> Components: dotnet
>Affects Versions: 3.4.0
> Environment: .NET Core 2.1.5
> Microsoft Azure
>Reporter: Saber Karmous
>Priority: Critical
>
> .NET Core 2.1.5
> Gremlin.NET 3.4.0-rc2
> We're using the latest RC of the Gremlin client. And we have a gremlin client
> that's being injected as a singleton through out IoC container. After running
> the backend for a day or two it keeps throwing System.IO.IOExceptions. If we
> restart the application it works again.
> We use Polly for out retry strategy, and retrying for 9 times. But it keeps
> failing.
> I added the stack trace below. Reproducing is a bit of a pain in the behind,
> you have to wait for a day or two for the exception to occur.
> {noformat}
> *no* System.IO.IOException:
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable+ConfiguredValueTaskAwaiter.GetResult
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Net.Security.SslStreamInternal+d`1.MoveNext
> (System.Net.Security, Version=4.1.1.0, Culture=neutral,
> PublicKeyToken=b03f5f7f11d50a3a)
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.ConfiguredValueTaskAwaitable+ConfiguredValueTaskAwaiter.GetResult
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Net.Security.SslStreamInternal+d`1.MoveNext
> (System.Net.Security, Version=4.1.1.0, Culture=neutral,
> PublicKeyToken=b03f5f7f11d50a3a)
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at Gremlin.Net.Driver.WebSocketConnection+d__7.MoveNext
> (Gremlin.Net, Version=3.4.0.0, Culture=neutral,
> PublicKeyToken=d2035e9aa387a711)
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at
> System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at Gremlin.Net.Driver.Connection+d__13.MoveNext (Gremlin.Net,
> Version=3.4.0.0, Culture=neutral, PublicKeyToken=d2035e9aa387a711)
> at System.Runtime.ExceptionServices.ExceptionDispatchInfo.Throw
> (System.Private.CoreLib, Version=4.0.0.0, Culture=neutral,
> PublicKeyToken=7cec85d7bea7798e)
> at System.Runtim
[jira] [Updated] (TINKERPOP-2132) In concurrent scenes kerberos authentication failed
[
https://issues.apache.org/jira/browse/TINKERPOP-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
kaiyangzhang updated TINKERPOP-2132:
Description:
*Scenes:*
1. Gremlin Server Kerberos Authentication
2. Multithreading using the same client
{code:java}
DriverRemoteConnection connection =
DriverRemoteConnection.using(cluster,"graphbase");
GraphTraversalSource g = graph.traversal().withRemote(connection);
Thread demo1 = new Thread(new ThreadDemo1(g));
Thread demo2 = new Thread(new ThreadDemo1(g));
Thread demo3 = new Thread(new ThreadDemo1(g));
Thread demo4 = new Thread(new ThreadDemo1(g));
Thread demo5 = new Thread(new ThreadDemo1(g));
Thread demo6 = new Thread(new ThreadDemo1(g));
Thread demo7 = new Thread(new ThreadDemo1(g));
Thread demo8 = new Thread(new ThreadDemo1(g));
Thread demo9 = new Thread(new ThreadDemo1(g));
Thread demo10 = new Thread(new ThreadDemo1(g));
{code}
*ERROR INFO*
{code:java}
Exception in thread "Thread-4" java.util.concurrent.CompletionException:
org.apache.tinkerpop.gremlin.driver.exception.ResponseException: Failed to
authenticate
at
java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375)
at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934)
at org.apache.tinkerpop.gremlin.driver.ResultSet.one(ResultSet.java:107)
at org.apache.tinkerpop.gremlin.driver.ResultSet$1.hasNext(ResultSet.java:159)
at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:166)
at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:153)
at
org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:142)
at
org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:127)
at
org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal.nextTraverser(DriverRemoteTraversal.java:108)
at
org.apache.tinkerpop.gremlin.process.remote.traversal.step.map.RemoteStep.processNextStart(RemoteStep.java:80)
at
org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143)
at
org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.hasNext(DefaultTraversal.java:192)
at com.huawei.graphbase.gremlin.ThreadDemo1.println(ThreadDemo1.java:48)
at com.huawei.graphbase.gremlin.ThreadDemo1.run(ThreadDemo1.java:32)
at java.lang.Thread.run(Thread.java:748)
Caused by: org.apache.tinkerpop.gremlin.driver.exception.ResponseException:
Failed to authenticate
at
org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:246)
at
org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:197)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351)
at
org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:123)
at
org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:67)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351)
at
io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351)
at
org.apache.tinkerpop.gremlin.driver.handler.WebSocketClientHandler.channelRead0(WebSocketClientHandler.java:94)
at
io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373)
at
io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359)
at
io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351)
at
io.netty.handler.codec.ByteToMessag
[jira] [Updated] (TINKERPOP-2132) In concurrent scenes kerberos authentication failed
[ https://issues.apache.org/jira/browse/TINKERPOP-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] kaiyangzhang updated TINKERPOP-2132: Description: *Scenes:* 1. Gremlin Server Kerberos Authentication 2. Multithreading using the same client DriverRemoteConnection connection = DriverRemoteConnection.using(cluster,"graphbase"); GraphTraversalSource g = graph.traversal().withRemote(connection); Thread demo1 = new Thread(new ThreadDemo1(g)); Thread demo2 = new Thread(new ThreadDemo1(g)); Thread demo3 = new Thread(new ThreadDemo1(g)); Thread demo4 = new Thread(new ThreadDemo1(g)); Thread demo5 = new Thread(new ThreadDemo1(g)); Thread demo6 = new Thread(new ThreadDemo1(g)); Thread demo7 = new Thread(new ThreadDemo1(g)); Thread demo8 = new Thread(new ThreadDemo1(g)); Thread demo9 = new Thread(new ThreadDemo1(g)); Thread demo10 = new Thread(new ThreadDemo1(g)); *ERROR INFO* Exception in thread "Thread-4" java.util.concurrent.CompletionException: org.apache.tinkerpop.gremlin.driver.exception.ResponseException: Failed to authenticate at java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375) at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934) at org.apache.tinkerpop.gremlin.driver.ResultSet.one(ResultSet.java:107) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.hasNext(ResultSet.java:159) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:166) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:153) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:142) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:127) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal.nextTraverser(DriverRemoteTraversal.java:108) at org.apache.tinkerpop.gremlin.process.remote.traversal.step.map.RemoteStep.processNextStart(RemoteStep.java:80) at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143) at org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.hasNext(DefaultTraversal.java:192) at com.huawei.graphbase.gremlin.ThreadDemo1.println(ThreadDemo1.java:48) at com.huawei.graphbase.gremlin.ThreadDemo1.run(ThreadDemo1.java:32) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.tinkerpop.gremlin.driver.exception.ResponseException: Failed to authenticate at org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:246) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:197) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:123) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:67) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at org.apache.tinkerpop.gremlin.driver.handler.WebSocketClientHandler.channelRead0(WebSocketClientHandler.java:94) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at io.netty.handler.codec.ByteToMessageDecoder.fireChannelRead(ByteToMessageDec
[jira] [Commented] (TINKERPOP-2132) In concurrent scenes kerberos authentication failed
[
https://issues.apache.org/jira/browse/TINKERPOP-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16741162#comment-16741162
]
kaiyangzhang commented on TINKERPOP-2132:
-
*Single thread during the certification process，the client sends 4 messages to
the server.*
1. RequestMessage\{, requestId=d67895c3-3b38-4462-96fc-bbe6b7c96bcb, op='eval',
processor='', args={gremlin=g.V().limit(1), aliases={g=graphbase},
batchSize=64}}
2. RequestMessage\{, requestId=f1202bea-143d-47a5-b6e1-3648430ad91d,
op='authentication', processor='',
args={sasl=YIICFwYJKoZIhvcSAQICAQBuggIGMIICAqADAgEFoQMCAQ6iBwMFACCjggEtYYIBKTCCASWgAwIBBaEMGwpIQURPT1AuQ09NoiIwIKADAgEAoRkwFxsNZ3JlbWxpbnNlcnZlchsGaGQtMTIzo4HrMIHooAMCARKhAwIBAaKB2wSB2CjuwlvwNMM6glPcBfLzNrzMyhISJQ9rjTNIHd9nOrpNQ3DC+EKh5YHAfTKVEK/E8FYyZ7JAk7YFtMKZuU9UzW65i7ws1miT1anBDVQRuFjNvz22JpmXeDFX0HAD0CmHRp5QF4HCz2OL287sb3zw+1n9NGy0cAKP5HHlC4moNiUI264kNnncxJZ5PxImHSv3SjtoQZSFB86Wtp6g/GldqNAQxlvSj31r/0N/0mjMrIJQHmtuPHq4tgSvfgkONkzS4XsTUEHEWTCdSjFOZWYFpiRHkR3vtqqvYKSBuzCBuKADAgERooGwBIGt3h7Rj/hzlrEKXWZHbI6y5bDRHKLHO9uI1PrZ8pJFhY09+9CJEsbLl1ZsJ7VAoN/bWehvBC1dm2s2mcv2ioaJGj68UQ9Rwv84NIsrwGJXXyWRAqf101QKooZDp5SN2rQUfyuDU9D3rx2KeKjyj4LB+a9W6/M1tcSTGegi6NJx1Q67lqCxAuoF9J5PV4jiWy2l5b4yVarsXiDsXH9F9DjcAXBXiOdDTgbPya7aRoQ=,
saslMechanism=GSSAPI}}
3. RequestMessage\{, requestId=f1989005-a4b1-400d-b217-07f11386776f,
op='authentication', processor='', args={sasl=}}
4. RequestMessage\{, requestId=1cae7453-1b07-4dab-bd66-327f9bae75c5,
op='authentication', processor='',
args={sasl=BQQA/wAMA/BaugEBAAByvEFL4nfhrCbI2SA=}}
*Multi-thread during the certification process, the client sends N messages to
the server.*
1. RequestMessage\{, requestId=79eab560-6ae9-49aa-8799-93041ab769a9, op='eval',
processor='', args={gremlin=g.V().limit(1), aliases={g=graphbase},
batchSize=64}}
{color:#FF}2. RequestMessage\{,
requestId=2e4c4e65-b0e5-460b-ae9f-0ec07cf0b30b, op='eval', processor='',
args={gremlin=g.V().limit(1), aliases={g=graphbase}, batchSize=64}}{color}
3. RequestMessage\{, requestId=c592c33a-2969-41d6-b76c-c952e73f0695,
op='authentication', processor='',
args={sasl=YIICFwYJKoZIhvcSAQICAQBuggIGMIICAqADAgEFoQMCAQ6iBwMFACCjggEtYYIBKTCCASWgAwIBBaEMGwpIQURPT1AuQ09NoiIwIKADAgEAoRkwFxsNZ3JlbWxpbnNlcnZlchsGaGQtMTIzo4HrMIHooAMCARKhAwIBAaKB2wSB2Dzq0SrzUybZVy5l8JfVdnn4/dQ4FC52icilKnjpalUcga8tb7Lx0bijjy3HLF980DAgPuYjuzccK0pWOaP2/U7lnixwnsWMUdSjNZsfYbYvYOmjbEUUAogkAGHe+Kkc2V8lu2+5oklLx+Sc00aIkLl1SoOSnisFgjQbj1mDuq+kwYqR9hNwXVLwnOjKeRglQZ1Ex3EQtAo342T55tFPRAEMi3p/VdLrodljWq/x0Iyz+i/le0YvaXVG368KzjCCJRy+xOWqKt9r1UrYWkNZvfh4FIsrBpmxsqSBuzCBuKADAgERooGwBIGtJfmCgMm8lJKclY1fx1KhtpLR91G1IFrKqCgmBVKXcUxI+lGKwXkesw/W6vHpCBrOdQtajHCvxcrIXK7HRIzmQ7qRBw8CRNalqmdn8gs8F/6WE0qB1WdT8TUGrInGxUmTJWSKmXKFKdA/kOQm/QFH4/ReBKByJKlwreSz0jm1Y0pDwUTPqGl4nbzm3U3c9xzwUPyKkij+yin/rPNdYQyEhWQxdep8b5RQv7nrMcg=,
saslMechanism=GSSAPI}}
4. RequestMessage\{, requestId=eafb-a32e-48a2-b5a5-cefdd4c38466,
op='authentication', processor='', args={sasl=}}
5. RequestMessage\{, requestId=a68f9641-6ed2-4ff0-8646-25c8ac2ef593,
op='authentication', processor='',
args={sasl=BQQA/wAMHwlwtAEBAACi6yiQAyWNt5ma6jw=}}
6. RequestMessage\{, requestId=4bdc358b-faef-46f2-8d80-507fcd972679, op='eval',
processor='', args={gremlin=g.V().limit(1), aliases={g=graphbase},
batchSize=64}}
7. RequestMessage\{, requestId=1279c920-b4a3-4ded-919b-52f28c1708f9,
op='authentication', processor='',
args={sasl=YIICFwYJKoZIhvcSAQICAQBuggIGMIICAqADAgEFoQMCAQ6iBwMFACCjggEtYYIBKTCCASWgAwIBBaEMGwpIQURPT1AuQ09NoiIwIKADAgEAoRkwFxsNZ3JlbWxpbnNlcnZlchsGaGQtMTIzo4HrMIHooAMCARKhAwIBAaKB2wSB2JzDBEKxpTDAbekuWTL/ReoyGPbXZA2RXHFUBbYe57KxLFisjJ3fQdXh57QEoKBhW6ChVhMSK9SvFWw8Ak+i/j2F8+MMxEXOPBVVybgX+g2bSjLR8/4rMbrPJ9Vn8E4T67KfB125A0/rzW9itnOVjC9UL68BLvikFpdEGL9FXDN0R2RY9gRQUy1jv6J5H1PdwH7SERxj8Ih+HcZgjRNj0+pwXYR0Phr5WJ7iTRfCmdfPFU54PpXzABk4X472MrnNaHWuwDKt1y8wmCCT8W8OJMP1A70XolV/zaSBuzCBuKADAgERooGwBIGtCOp4CFXaccRG9vrjFpM66C5/ts8Y6EoiCMhFzEveoSchhgxMr9mrO8g2ai+pA26qpNCw4tc5jfr3loLUZKljf932exkoo3svhQaKT+i75GG862G2y6YLebgyac7DBRDs46f9uY+tBqIseyNoMvLlNfUafaI6XUBENNuvQLDTyXYaNleWOOWc373PZXDXJykGk14vvFf5aJlFTNb97QuyEdjHC+WR0T0MQuxVH2M=,
saslMechanism=GSSAPI}}
8. RequestMessage\{, requestId=297049c1-0b37-42fa-9a48-44f461fb4a17,
op='authentication', processor='', args={sasl=}}
9. RequestMessage\{, requestId=09562c7f-a718-4275-9939-3fccfbc8cd3a,
op='authentication', processor='',
args={sasl=BQQA/wAMJTWW2wEBAAA3tCN1iWHrS4Z07Ac=}}
> In concurrent scenes kerberos authentication failed
> ---
>
> Key: TINKERPOP-2132
> URL: https://issues.apache.org/jira/browse/TINKERPOP-2132
> Project: TinkerPop
> Issue Type: Bug
> Components: driver, server
>Affects Versions: 3.3.2
>Reporter: kaiyangzhang
>
[jira] [Created] (TINKERPOP-2132) In concurrent scenes kerberos authentication failed
kaiyangzhang created TINKERPOP-2132: --- Summary: In concurrent scenes kerberos authentication failed Key: TINKERPOP-2132 URL: https://issues.apache.org/jira/browse/TINKERPOP-2132 Project: TinkerPop Issue Type: Bug Components: driver, server Affects Versions: 3.3.2 Reporter: kaiyangzhang *Scenes:* 1. Gremlin Server Kerberos Authentication 2. Multithreading using the same client DriverRemoteConnection connection = DriverRemoteConnection.using(cluster,"graphbase"); GraphTraversalSource g = graph.traversal().withRemote(connection); Thread demo1 = new Thread(new ThreadDemo1(g)); Thread demo2 = new Thread(new ThreadDemo1(g)); Thread demo3 = new Thread(new ThreadDemo1(g)); Thread demo4 = new Thread(new ThreadDemo1(g)); Thread demo5 = new Thread(new ThreadDemo1(g)); Thread demo6 = new Thread(new ThreadDemo1(g)); Thread demo7 = new Thread(new ThreadDemo1(g)); Thread demo8 = new Thread(new ThreadDemo1(g)); Thread demo9 = new Thread(new ThreadDemo1(g)); Thread demo10 = new Thread(new ThreadDemo1(g)); *ERROR INFO* Exception in thread "Thread-4" java.util.concurrent.CompletionException: org.apache.tinkerpop.gremlin.driver.exception.ResponseException: Failed to authenticate at java.util.concurrent.CompletableFuture.reportJoin(CompletableFuture.java:375) at java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1934) at org.apache.tinkerpop.gremlin.driver.ResultSet.one(ResultSet.java:107) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.hasNext(ResultSet.java:159) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:166) at org.apache.tinkerpop.gremlin.driver.ResultSet$1.next(ResultSet.java:153) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:142) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal$TraverserIterator.next(DriverRemoteTraversal.java:127) at org.apache.tinkerpop.gremlin.driver.remote.DriverRemoteTraversal.nextTraverser(DriverRemoteTraversal.java:108) at org.apache.tinkerpop.gremlin.process.remote.traversal.step.map.RemoteStep.processNextStart(RemoteStep.java:80) at org.apache.tinkerpop.gremlin.process.traversal.step.util.AbstractStep.hasNext(AbstractStep.java:143) at org.apache.tinkerpop.gremlin.process.traversal.util.DefaultTraversal.hasNext(DefaultTraversal.java:192) at com.huawei.graphbase.gremlin.ThreadDemo1.println(ThreadDemo1.java:48) at com.huawei.graphbase.gremlin.ThreadDemo1.run(ThreadDemo1.java:32) at java.lang.Thread.run(Thread.java:748) Caused by: org.apache.tinkerpop.gremlin.driver.exception.ResponseException: Failed to authenticate at org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:246) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinResponseHandler.channelRead0(Handler.java:197) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:123) at org.apache.tinkerpop.gremlin.driver.Handler$GremlinSaslAuthenticationHandler.channelRead0(Handler.java:67) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at io.netty.handler.codec.MessageToMessageDecoder.channelRead(MessageToMessageDecoder.java:102) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:351) at org.apache.tinkerpop.gremlin.driver.handler.WebSocketClientHandler.channelRead0(WebSocketClientHandler.java:94) at io.netty.channel.SimpleChannelInboundHandler.channelRead(SimpleChannelInboundHandler.java:105) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:373) at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:359) at io.netty.channel.AbstractChannelHandlerConte
