Skip to content

Instantly share code, notes, and snippets.

@nivekastoreth

nivekastoreth/lettuce-correct-queue.log

Created April 20, 2018 16:58
Show Gist options
  • Save nivekastoreth/d934ac60488604baa11be770ed7d1c71 to your computer and use it in GitHub Desktop.
Save nivekastoreth/d934ac60488604baa11be770ed7d1c71 to your computer and use it in GitHub Desktop.
Download ZIP
Lettuce Client: DefaultEndpoint.QUEUE_SIZE becomes out of sync, preventing command queueing
Raw
lettuce-correct-queue.log
# After each `Breakpoint reached` follows the stacktrace of where that breakpoint was, and after that it prints the value of `DefaultEndpoint.QUEUE_SIZE`
2018-04-20 14:40:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
0
2018-04-20 14:40:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:40:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Received: 8 bytes, 1 commands in the stack
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Buffer: $2
{}
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 1 commands
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:40:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:41:40 UTC [disruptor-http-inbound-3] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:41:40 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:41:40 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Received: 8 bytes, 1 commands in the stack
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Buffer: $2
{}
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 1 commands
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:41:40 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
Raw
lettuce-incorrect-queue-breaking.log
# After each `Breakpoint reached` follows the stacktrace of where that breakpoint was, and after that it prints the value of `DefaultEndpoint.QUEUE_SIZE`
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-1] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-3] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:52 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
2018-04-20 14:43:52 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [redis-read-4] ERROR c.n.h.s.r.e.r.RedisScript$ - Error while running redis script
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:112)
at io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:426)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.l.c.p.DefaultEndpoint - Unexpected exception during request: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.n.c.AbstractChannelHandlerContext - Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@4a01a122(failure: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.), unnotified cause: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.requeueCommands(DefaultEndpoint.java:843)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.lambda$doComplete$0(DefaultEndpoint.java:819)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener$$Lambda$51.1411256815.run(Unknown Source:-1)
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:73)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
0
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-2] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [redis-read-1] ERROR c.n.h.s.r.e.r.RedisScript$ - Error while running redis script
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:112)
at io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:426)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.l.c.p.DefaultEndpoint - Unexpected exception during request: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.n.c.AbstractChannelHandlerContext - Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@767f9e41(failure: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.), unnotified cause: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.requeueCommands(DefaultEndpoint.java:843)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.lambda$doComplete$0(DefaultEndpoint.java:819)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener$$Lambda$51.1411256815.run(Unknown Source:-1)
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:73)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
1
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
2
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-1] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [redis-read-2] ERROR c.n.h.s.r.e.r.RedisScript$ - Error while running redis script
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:112)
at io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:426)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
3
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.l.c.p.DefaultEndpoint - Unexpected exception during request: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.n.c.AbstractChannelHandlerContext - Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@41a2415d(failure: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.), unnotified cause: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.requeueCommands(DefaultEndpoint.java:843)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.lambda$doComplete$0(DefaultEndpoint.java:819)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener$$Lambda$51.1411256815.run(Unknown Source:-1)
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:73)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
3
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-4] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [redis-read-5] ERROR c.n.h.s.r.e.r.RedisScript$ - Error while running redis script
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:112)
at io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:426)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
4
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.l.c.p.DefaultEndpoint - Unexpected exception during request: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.n.c.AbstractChannelHandlerContext - Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@61c584a7(failure: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.), unnotified cause: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.requeueCommands(DefaultEndpoint.java:843)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.lambda$doComplete$0(DefaultEndpoint.java:819)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener$$Lambda$51.1411256815.run(Unknown Source:-1)
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:73)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
3
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
4
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [disruptor-http-inbound-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [redis-read-3] ERROR c.n.h.s.r.e.r.RedisScript$ - Error while running redis script
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:485)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.setFailure(DefaultPromise.java:112)
at io.netty.channel.DefaultChannelPromise.setFailure(DefaultChannelPromise.java:89)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:426)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
5
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.l.c.p.DefaultEndpoint - Unexpected exception during request: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] WARN i.n.c.AbstractChannelHandlerContext - Failed to mark a promise as failure because it has failed already: DefaultChannelPromise@4706b819(failure: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.), unnotified cause: io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
io.lettuce.core.RedisException: Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.
at io.lettuce.core.protocol.CommandHandler.validateWrite(CommandHandler.java:441)
at io.lettuce.core.protocol.CommandHandler.addToStack(CommandHandler.java:410)
at io.lettuce.core.protocol.CommandHandler.writeSingleCommand(CommandHandler.java:367)
at io.lettuce.core.protocol.CommandHandler.write(CommandHandler.java:334)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:738)
at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:730)
at io.netty.channel.AbstractChannelHandlerContext.access$1900(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.write(AbstractChannelHandlerContext.java:1081)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1128)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.requeueCommands(DefaultEndpoint.java:843)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.lambda$doComplete$0(DefaultEndpoint.java:819)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener$$Lambda$51.1411256815.run(Unknown Source:-1)
at io.netty.util.concurrent.PromiseTask$RunnableAdapter.call(PromiseTask.java:38)
at io.netty.util.concurrent.PromiseTask.run(PromiseTask.java:73)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
4
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='Internal stack size exceeded: 10. Commands are not accepted until the stack size drops.'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:43:53 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Received: 120 bytes, 15 commands in the stack
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Buffer: $2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
$2
{}
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 15 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 14 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 13 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 12 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 11 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 10 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 9 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 8 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 7 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 6 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 5 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 4 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 3 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 2 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 1 commands
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:20 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
Raw
lettuce-incorrect-queue-broken.log
# After each `Breakpoint reached` follows the stacktrace of where that breakpoint was, and after that it prints the value of `DefaultEndpoint.QUEUE_SIZE`
2018-04-20 14:44:38 UTC [disruptor-http-inbound-5] DEBUG i.l.c.RedisChannelHandler - dispatching command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint.writeToChannelAndFlush(DefaultEndpoint.java:256)
at io.lettuce.core.protocol.DefaultEndpoint.write(DefaultEndpoint.java:118)
at io.lettuce.core.RedisChannelHandler.dispatch(RedisChannelHandler.java:123)
at io.lettuce.core.StatefulRedisConnectionImpl.dispatch(StatefulRedisConnectionImpl.java:152)
at io.lettuce.core.AbstractRedisAsyncCommands.dispatch(AbstractRedisAsyncCommands.java:461)
at io.lettuce.core.AbstractRedisAsyncCommands.evalsha(AbstractRedisAsyncCommands.java:499)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1$$anonfun$apply$7.apply(RedisScript.scala:110)
at scalaz.$bslash$div.fold(Either.scala:57)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$$anonfun$1.apply(RedisScript.scala:109)
at scalaz.$bslash$div$.fromTryCatchNonFatal(Either.scala:378)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$.com$ntoggle$helix$service$requests$enrich$redis$RedisScript$$evalFuture(RedisScript.scala:108)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:38)
at com.ntoggle.helix.service.requests.enrich.redis.RedisScript$RecoveringRedisScript$$anonfun$eval$1.apply(RedisScript.scala:37)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListenInterruptibly(Future.scala:97)
at scalaz.concurrent.Future.unsafePerformAsyncInterruptibly(Future.scala:172)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:261)
at scalaz.concurrent.Future$$anonfun$timed$1.apply(Future.scala:248)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future$$anonfun$async$1.apply(Future.scala:428)
at scalaz.concurrent.Future.unsafePerformListen(Future.scala:79)
at scalaz.concurrent.Future.unsafePerformAsync(Future.scala:159)
at scalaz.concurrent.Task.unsafePerformAsync(Task.scala:170)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$.com$ntoggle$helix$service$supplypartners$http$HttpSupplyPartnerEndpoint$$handleRequest(HttpSupplyPartnerEndpoint.scala:81)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.helix.service.supplypartners.http.HttpSupplyPartnerEndpoint$$anonfun$5.apply(HttpSupplyPartnerEndpoint.scala:182)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:124)
at com.ntoggle.stack.netty.http.NettyHttp$$anonfun$1.apply(NettyHttp.scala:123)
at com.ntoggle.stack.disp.RingBufferDispatch$$anonfun$1$$anon$1.onEvent(RingBufferDispatch.scala:43)
at com.lmax.disruptor.WorkProcessor.run(WorkProcessor.java:143)
at java.lang.Thread.run(Thread.java:745)
5
2018-04-20 14:44:38 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() writeAndFlush command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:38 UTC [disruptor-http-inbound-5] DEBUG i.l.c.p.DefaultEndpoint - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, epid=0x2] write() done
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] write(ctx, AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command], promise)
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] writing command AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandEncoder - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634] Sent: *5
$7
EVALSHA
$40
7f95318ed2a2462ea8d560f6aa8bb5d698df46a5
$1
1
$36
AEBE52E7-03EE-455A-B3C4-E57283966239
$1
*
Breakpoint reached
at io.lettuce.core.protocol.DefaultEndpoint$ListenerSupport.dequeue(DefaultEndpoint.java:664)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.doComplete(DefaultEndpoint.java:800)
at io.lettuce.core.protocol.DefaultEndpoint$RetryListener.operationComplete(DefaultEndpoint.java:789)
at io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:511)
at io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:504)
at io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:483)
at io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:424)
at io.netty.util.concurrent.DefaultPromise.trySuccess(DefaultPromise.java:103)
at io.netty.util.internal.PromiseNotificationUtil.trySuccess(PromiseNotificationUtil.java:48)
at io.netty.channel.ChannelOutboundBuffer.safeSuccess(ChannelOutboundBuffer.java:697)
at io.netty.channel.ChannelOutboundBuffer.remove(ChannelOutboundBuffer.java:259)
at io.netty.channel.ChannelOutboundBuffer.removeBytes(ChannelOutboundBuffer.java:339)
at io.netty.channel.socket.nio.NioSocketChannel.doWrite(NioSocketChannel.java:409)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush0(AbstractChannel.java:934)
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.flush0(AbstractNioChannel.java:360)
at io.netty.channel.AbstractChannel$AbstractUnsafe.flush(AbstractChannel.java:901)
at io.netty.channel.DefaultChannelPipeline$HeadContext.flush(DefaultChannelPipeline.java:1376)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelOutboundHandlerAdapter.flush(ChannelOutboundHandlerAdapter.java:115)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.flush(AbstractChannelHandlerContext.java:749)
at io.netty.channel.ChannelDuplexHandler.flush(ChannelDuplexHandler.java:117)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush0(AbstractChannelHandlerContext.java:776)
at io.netty.channel.AbstractChannelHandlerContext.invokeFlush(AbstractChannelHandlerContext.java:768)
at io.netty.channel.AbstractChannelHandlerContext.access$1500(AbstractChannelHandlerContext.java:38)
at io.netty.channel.AbstractChannelHandlerContext$WriteAndFlushTask.write(AbstractChannelHandlerContext.java:1129)
at io.netty.channel.AbstractChannelHandlerContext$AbstractWriteTask.run(AbstractChannelHandlerContext.java:1070)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:163)
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:-1)
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:404)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:463)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:886)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.lang.Thread.run(Thread.java:745)
6
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Received: 8 bytes, 1 commands in the stack
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] TRACE i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Buffer: $2
{}
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.CommandHandler - [channel=0x623c7065, /127.0.0.1:50087 -> localhost/127.0.0.1:8634, chid=0x4] Stack contains: 1 commands
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decode AsyncCommand [type=EVALSHA, output=ValueOutput [output=null, error='null'], commandType=io.lettuce.core.protocol.Command]
2018-04-20 14:44:38 UTC [lettuce-nioEventLoop-10-3] DEBUG i.l.c.p.RedisStateMachine - Decoded AsyncCommand [type=EVALSHA, output=ValueOutput [output={}, error='null'], commandType=io.lettuce.core.protocol.Command], empty stack: true
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment