Galen O'Sullivan created GEODE-2435:
---------------------------------------
Summary: Redis adapter MULTI behavior is different from Redis
Key: GEODE-2435
URL: https://issues.apache.org/jira/browse/GEODE-2435
Project: Geode
Issue Type: Bug
Reporter: Galen O'Sullivan
{{WATCH}} isn't implemented properly, but this is about returning an error
instead of nil when we have a {{MULTI}} fail:
{code}
$ redis-cli -p 11212
127.0.0.1:11212> set a b
OK
127.0.0.1:11212> watch a
(error) ERR Keys cannot be watched or unwatched because GemFire watches all
keys by default for transactions
127.0.0.1:11212> lpush la boo
(integer) 1
(2.09s)
127.0.0.1:11212> multi
OK
127.0.0.1:11212> lpush la z
QUEUED
127.0.0.1:11212> lpush la x
QUEUED
{code}
At this point, we {{lpush la foo}} in a different client, then:
{code}
127.0.0.1:11212> exec
1) (error) ERR The server had an internal error please try again
2) (error) ERR The server had an internal error please try again
127.0.0.1:11212>
{code}
whereas a Redis instance will simply return nil instead of an error.
Looking in the logs, I see this:
{code}
[error 2017/02/06 13:21:39.493 PST server2 <GeodeRedisServer-WorkerThread-2>
tid=0x2a] GeodeRedisServer-Unexpected error handler for [id: 0x3ddf9f21,
/127.0.0.1:58862 => /127.0.0.1:11212]
java.lang.UnsupportedOperationException: Operations on persist-backup regions
are not allowed because this thread has an active transaction
at
org.apache.geode.internal.cache.TXRegionState.<init>(TXRegionState.java:60)
at
org.apache.geode.internal.cache.TXBucketRegionState.<init>(TXBucketRegionState.java:29)
at org.apache.geode.internal.cache.TXState.writeRegion(TXState.java:252)
at
org.apache.geode.internal.cache.TXState.txWriteRegion(TXState.java:1110)
at
org.apache.geode.internal.cache.TXState.txReadEntry(TXState.java:1365)
at
org.apache.geode.internal.cache.TXState.txReadEntry(TXState.java:1344)
at
org.apache.geode.internal.cache.TXState.getDeserializedValue(TXState.java:1414)
at
org.apache.geode.internal.cache.TXStateProxyImpl.getDeserializedValue(TXStateProxyImpl.java:352)
at
org.apache.geode.internal.cache.LocalRegion.get(LocalRegion.java:1394)
at
org.apache.geode.internal.cache.PartitionedRegionDataStore.getLocally(PartitionedRegionDataStore.java:2047)
at
org.apache.geode.internal.cache.PartitionedRegion.getFromBucket(PartitionedRegion.java:4022)
at
org.apache.geode.internal.cache.PartitionedRegion.findObjectInSystem(PartitionedRegion.java:3399)
at org.apache.geode.internal.cache.TXState.findObject(TXState.java:1540)
at
org.apache.geode.internal.cache.TXStateProxyImpl.findObject(TXStateProxyImpl.java:614)
at
org.apache.geode.internal.cache.PartitionedRegion.get(PartitionedRegion.java:3160)
at
org.apache.geode.internal.cache.LocalRegion.get(LocalRegion.java:1330)
at
org.apache.geode.internal.cache.AbstractRegion.get(AbstractRegion.java:282)
at
org.apache.geode.redis.internal.executor.list.ListExecutor.pushElements(ListExecutor.java:70)
at
org.apache.geode.redis.internal.executor.list.PushExecutor.executeCommand(PushExecutor.java:47)
at
org.apache.geode.redis.internal.ExecutionHandlerContext.executeWithTransaction(ExecutionHandlerContext.java:244)
at
org.apache.geode.redis.internal.ExecutionHandlerContext.executeCommand(ExecutionHandlerContext.java:191)
at
org.apache.geode.redis.internal.ExecutionHandlerContext.channelRead(ExecutionHandlerContext.java:137)
at
io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:368)
at
io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:353)
at
io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:173)
at
io.netty.channel.DefaultChannelHandlerContext.invokeChannelRead(DefaultChannelHandlerContext.java:368)
at
io.netty.channel.DefaultChannelHandlerContext.fireChannelRead(DefaultChannelHandlerContext.java:353)
at
io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:780)
at
io.netty.channel.nio.AbstractNioByteChannel$NioByteUnsafe.read(AbstractNioByteChannel.java:100)
at
io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:497)
at
io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:465)
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:359)
at
io.netty.util.concurrent.SingleThreadEventExecutor$2.run(SingleThreadEventExecutor.java:101)
at java.lang.Thread.run(Thread.java:745)
{code}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
