This looks like the persistence with transactions issue that Gemfire has. There is a system property to allow it to work
-- Mike Stolz Principal Engineer - Gemfire Product Manager Mobile: 631-835-4771 On Feb 6, 2017 4:41 PM, "Galen O'Sullivan (JIRA)" <j...@apache.org> wrote: > 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) >
