[JBoss JIRA] (ISPN-2575) Key Transformer registration is required on all nodes of the cluster, in case of custom keys
by Tristan Tarrant (Jira)
[ https://issues.redhat.com/browse/ISPN-2575?page=com.atlassian.jira.plugin... ]
Tristan Tarrant updated ISPN-2575:
----------------------------------
Status: Open (was: Pull Request Sent)
> Key Transformer registration is required on all nodes of the cluster, in case of custom keys
> --------------------------------------------------------------------------------------------
>
> Key: ISPN-2575
> URL: https://issues.redhat.com/browse/ISPN-2575
> Project: Infinispan
> Issue Type: Enhancement
> Components: Embedded Querying
> Affects Versions: 5.2.0.Beta5
> Reporter: Anna Manukyan
> Assignee: Nistor Adrian
> Priority: Minor
> Fix For: 10.1.0.Final
>
> Attachments: ClusteredCacheTest.java
>
>
> The case is the following:
> I have a clustered cache on which I want to perform a search. I'm doing the following:
> I'm initializing SearchManager on node1, I'm registering a custom key transformer for my key using the created searchmanager, but then when I'm trying to put data into the cache on node1 (which is in REPL_SYNC mode with cache on node2), I'm getting the exception:
> java.lang.IllegalArgumentException: Indexing only works with entries keyed on Strings, primitives and classes that have the @Transformable annotation - you passed in a class org.infinispan.query.test.CustomKey3. Alternatively, see org.infinispan.query.SearchManager#registerKeyTransformer
> When I'm initializing the SearchManager using node2 cache and register the keyTransformer on it as well, then everything works perfectly, even though I am not using the second created SearchManager.
> The test which reproduces the issue is attached to the jira. Please see the test case: testSearchKeyTransformer()
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
6 years, 1 month
[JBoss JIRA] (ISPN-11337) SQL server exception purging data
by Ryan Emerson (Jira)
Ryan Emerson created ISPN-11337:
-----------------------------------
Summary: SQL server exception purging data
Key: ISPN-11337
URL: https://issues.redhat.com/browse/ISPN-11337
Project: Infinispan
Issue Type: Bug
Components: Loaders and Stores
Affects Versions: 10.0.1.Final, 10.1.2.Final
Reporter: Megan van de Valk
Assignee: Ryan Emerson
When using string keyed jdbc store with dialect="SQL_SERVER" a SQL exception of 'FOR UPDATE clause allowed only for DECLARE CURSOR' is thrown.
{code:java}
14:57:39,444 WARN [org.infinispan.PERSISTENCE] (expiration-thread--p7-t1) ISPN000026: Caught exception purging data container!: org.infinispan.persistence.spi.PersistenceException: Failed clearing string based JDBC store
at org.infinispan.persistence.jdbc.stringbased.JdbcStringBasedStore.purge(JdbcStringBasedStore.java:502)
at org.infinispan.persistence.spi.SegmentedAdvancedLoadWriteStore.purge(SegmentedAdvancedLoadWriteStore.java:291)
at org.infinispan.persistence.manager.PersistenceManagerImpl.lambda$purgeExpired$8(PersistenceManagerImpl.java:522)
at java.util.ArrayList.forEach(ArrayList.java:1257)
at org.infinispan.persistence.manager.PersistenceManagerImpl.purgeExpired(PersistenceManagerImpl.java:528)
at org.infinispan.persistence.support.DelegatingPersistenceManager.purgeExpired(DelegatingPersistenceManager.java:90)
at org.infinispan.expiration.impl.ExpirationManagerImpl.processExpiration(ExpirationManagerImpl.java:120)
at org.infinispan.expiration.impl.ExpirationManagerImpl$ScheduledTask.run(ExpirationManagerImpl.java:282)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180)
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: com.microsoft.sqlserver.jdbc.SQLServerException: Line 1: FOR UPDATE clause allowed only for DECLARE CURSOR.
at com.microsoft.sqlserver.jdbc.SQLServerException.makeFromDatabaseError(SQLServerException.java:216)
at com.microsoft.sqlserver.jdbc.SQLServerStatement.getNextResult(SQLServerStatement.java:1515)
at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.doExecutePreparedStatement(SQLServerPreparedStatement.java:404)
at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement$PrepStmtExecCmd.doExecute(SQLServerPreparedStatement.java:350)
at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:5696)
at com.microsoft.sqlserver.jdbc.SQLServerConnection.executeCommand(SQLServerConnection.java:1715)
at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeCommand(SQLServerStatement.java:180)
at com.microsoft.sqlserver.jdbc.SQLServerStatement.executeStatement(SQLServerStatement.java:155)
at com.microsoft.sqlserver.jdbc.SQLServerPreparedStatement.executeQuery(SQLServerPreparedStatement.java:285)
at org.infinispan.persistence.jdbc.stringbased.JdbcStringBasedStore.purge(JdbcStringBasedStore.java:467)
... 14 more
{code}
The method initSelectOnlyExpiredRowsSql in [AbstractTableManager|https://github.com/infinispan/infinispan/blob/master...] includes a FOR UPDATE:
{code:java}
return String.format("%1$s WHERE %2$s < ? AND %2$s > 0 FOR UPDATE", getLoadAllRowsSql(), config.timestampColumnName());
{code}
It should probably be overwritten in [SQLServerTableManger|https://github.com/infinispan/infinispan/blob/master...] with
{code:java}
return String.format("%1$s WITH(UPDLOCK) WHERE %2$s < ? AND %2$s > 0", getLoadAllRowsSql(), config.timestampColumnName());
{code}
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
6 years, 1 month
[JBoss JIRA] (ISPN-10760) nodejs-client fails when tries to use custom event converters
by Anna Manukyan (Jira)
[ https://issues.redhat.com/browse/ISPN-10760?page=com.atlassian.jira.plugi... ]
Anna Manukyan updated ISPN-10760:
---------------------------------
Description:
When the nodejs-client connects to ServerNG and tries to use a custome event converter the operation fails with exception:
{code}
12:39:42,721 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (SINGLE_PORT-ServerIO-5-13) ISPN000136: Error executing command PutMapCommand on Cache 'default', writing keys [WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\3\"\}, hashCode=1235679806}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\1\"\}, hashCode=1235677884}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\2\"\}, hashCode=1235678845}]: org.infinispan.commons.dataconversion.EncodingException: ISPN000934: Unsupported content '[B@204b7b49'
at org.infinispan.commons.dataconversion.BinaryTranscoder.transcode(BinaryTranscoder.java:67)
at org.infinispan.encoding.DataConversion.convert(DataConversion.java:144)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.convertKey(CacheNotifierImpl.java:312)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.configureEvent(CacheNotifierImpl.java:515)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.doNotifyCreated(CacheNotifierImpl.java:406)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.notifyCacheEntryCreated(CacheNotifierImpl.java:390)
at org.infinispan.interceptors.impl.CallInterceptor.visitPutMapCommand(CallInterceptor.java:481)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.impl.CallInterceptor.visitCommand(CallInterceptor.java:166)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:81)
at org.infinispan.interceptors.impl.EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(EntryWrappingInterceptor.java:658)
at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutMapCommand(EntryWrappingInterceptor.java:412)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndFinally(BaseAsyncInterceptor.java:155)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.lambda$nonTxLockAndInvokeNext$3(AbstractLockingInterceptor.java:308)
at org.infinispan.interceptors.SyncInvocationStage.andHandle(SyncInvocationStage.java:70)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.nonTxLockAndInvokeNext(AbstractLockingInterceptor.java:303)
at org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor.handleWriteManyCommand(NonTransactionalLockingInterceptor.java:65)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.visitPutMapCommand(AbstractLockingInterceptor.java:182)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutMapCommand(CacheMgmtInterceptor.java:162)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53)
at org.infinispan.interceptors.DDAsyncInterceptor.visitPutMapCommand(DDAsyncInterceptor.java:89)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128)
at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89)
at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invokeAsync(AsyncInterceptorChainImpl.java:226)
at org.infinispan.cache.impl.CacheImpl.executeCommandAndCommitIfNeededAsync(CacheImpl.java:1847)
at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1508)
at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1501)
at org.infinispan.cache.impl.AbstractDelegatingAdvancedCache.putAllAsync(AbstractDelegatingAdvancedCache.java:460)
at org.infinispan.cache.impl.EncoderCache.putAllAsync(EncoderCache.java:303)
at org.infinispan.server.hotrod.CacheRequestProcessor.putAllInternal(CacheRequestProcessor.java:415)
at org.infinispan.server.hotrod.CacheRequestProcessor.putAll(CacheRequestProcessor.java:410)
at org.infinispan.server.hotrod.HotRodDecoder.switch3(HotRodDecoder.java:1836)
at org.infinispan.server.hotrod.HotRodDecoder.switch1_0(HotRodDecoder.java:156)
at org.infinispan.server.hotrod.HotRodDecoder.decode(HotRodDecoder.java:143)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:505)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:444)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:283)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
at org.infinispan.server.core.transport.StatsChannelHandler.channelRead(StatsChannelHandler.java:26)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1421)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930)
at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:794)
at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:424)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:326)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
{code}
was:
When the nodejs-client connects to ServerNG and tries to use a custome event converter, or run iterator, the operation fails with exception:
{code}
12:39:42,721 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (SINGLE_PORT-ServerIO-5-13) ISPN000136: Error executing command PutMapCommand on Cache 'default', writing keys [WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\3\"\}, hashCode=1235679806}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\1\"\}, hashCode=1235677884}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\2\"\}, hashCode=1235678845}]: org.infinispan.commons.dataconversion.EncodingException: ISPN000934: Unsupported content '[B@204b7b49'
at org.infinispan.commons.dataconversion.BinaryTranscoder.transcode(BinaryTranscoder.java:67)
at org.infinispan.encoding.DataConversion.convert(DataConversion.java:144)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.convertKey(CacheNotifierImpl.java:312)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.configureEvent(CacheNotifierImpl.java:515)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.doNotifyCreated(CacheNotifierImpl.java:406)
at org.infinispan.notifications.cachelistener.CacheNotifierImpl.notifyCacheEntryCreated(CacheNotifierImpl.java:390)
at org.infinispan.interceptors.impl.CallInterceptor.visitPutMapCommand(CallInterceptor.java:481)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.impl.CallInterceptor.visitCommand(CallInterceptor.java:166)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:81)
at org.infinispan.interceptors.impl.EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(EntryWrappingInterceptor.java:658)
at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutMapCommand(EntryWrappingInterceptor.java:412)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndFinally(BaseAsyncInterceptor.java:155)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.lambda$nonTxLockAndInvokeNext$3(AbstractLockingInterceptor.java:308)
at org.infinispan.interceptors.SyncInvocationStage.andHandle(SyncInvocationStage.java:70)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.nonTxLockAndInvokeNext(AbstractLockingInterceptor.java:303)
at org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor.handleWriteManyCommand(NonTransactionalLockingInterceptor.java:65)
at org.infinispan.interceptors.locking.AbstractLockingInterceptor.visitPutMapCommand(AbstractLockingInterceptor.java:182)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutMapCommand(CacheMgmtInterceptor.java:162)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53)
at org.infinispan.interceptors.DDAsyncInterceptor.visitPutMapCommand(DDAsyncInterceptor.java:89)
at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128)
at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89)
at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invokeAsync(AsyncInterceptorChainImpl.java:226)
at org.infinispan.cache.impl.CacheImpl.executeCommandAndCommitIfNeededAsync(CacheImpl.java:1847)
at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1508)
at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1501)
at org.infinispan.cache.impl.AbstractDelegatingAdvancedCache.putAllAsync(AbstractDelegatingAdvancedCache.java:460)
at org.infinispan.cache.impl.EncoderCache.putAllAsync(EncoderCache.java:303)
at org.infinispan.server.hotrod.CacheRequestProcessor.putAllInternal(CacheRequestProcessor.java:415)
at org.infinispan.server.hotrod.CacheRequestProcessor.putAll(CacheRequestProcessor.java:410)
at org.infinispan.server.hotrod.HotRodDecoder.switch3(HotRodDecoder.java:1836)
at org.infinispan.server.hotrod.HotRodDecoder.switch1_0(HotRodDecoder.java:156)
at org.infinispan.server.hotrod.HotRodDecoder.decode(HotRodDecoder.java:143)
at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:505)
at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:444)
at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:283)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
at org.infinispan.server.core.transport.StatsChannelHandler.channelRead(StatsChannelHandler.java:26)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1421)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930)
at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:794)
at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:424)
at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:326)
at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
at java.base/java.lang.Thread.run(Thread.java:834)
{code}
> nodejs-client fails when tries to use custom event converters
> -------------------------------------------------------------
>
> Key: ISPN-10760
> URL: https://issues.redhat.com/browse/ISPN-10760
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 10.0.0.CR3
> Reporter: Anna Manukyan
> Assignee: Ryan Emerson
> Priority: Major
>
> When the nodejs-client connects to ServerNG and tries to use a custome event converter the operation fails with exception:
> {code}
> 12:39:42,721 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (SINGLE_PORT-ServerIO-5-13) ISPN000136: Error executing command PutMapCommand on Cache 'default', writing keys [WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\3\"\}, hashCode=1235679806}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\1\"\}, hashCode=1235677884}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\2\"\}, hashCode=1235678845}]: org.infinispan.commons.dataconversion.EncodingException: ISPN000934: Unsupported content '[B@204b7b49'
> at org.infinispan.commons.dataconversion.BinaryTranscoder.transcode(BinaryTranscoder.java:67)
> at org.infinispan.encoding.DataConversion.convert(DataConversion.java:144)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.convertKey(CacheNotifierImpl.java:312)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.configureEvent(CacheNotifierImpl.java:515)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.doNotifyCreated(CacheNotifierImpl.java:406)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.notifyCacheEntryCreated(CacheNotifierImpl.java:390)
> at org.infinispan.interceptors.impl.CallInterceptor.visitPutMapCommand(CallInterceptor.java:481)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.impl.CallInterceptor.visitCommand(CallInterceptor.java:166)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:81)
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(EntryWrappingInterceptor.java:658)
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutMapCommand(EntryWrappingInterceptor.java:412)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndFinally(BaseAsyncInterceptor.java:155)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.lambda$nonTxLockAndInvokeNext$3(AbstractLockingInterceptor.java:308)
> at org.infinispan.interceptors.SyncInvocationStage.andHandle(SyncInvocationStage.java:70)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.nonTxLockAndInvokeNext(AbstractLockingInterceptor.java:303)
> at org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor.handleWriteManyCommand(NonTransactionalLockingInterceptor.java:65)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.visitPutMapCommand(AbstractLockingInterceptor.java:182)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutMapCommand(CacheMgmtInterceptor.java:162)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53)
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutMapCommand(DDAsyncInterceptor.java:89)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128)
> at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89)
> at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invokeAsync(AsyncInterceptorChainImpl.java:226)
> at org.infinispan.cache.impl.CacheImpl.executeCommandAndCommitIfNeededAsync(CacheImpl.java:1847)
> at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1508)
> at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1501)
> at org.infinispan.cache.impl.AbstractDelegatingAdvancedCache.putAllAsync(AbstractDelegatingAdvancedCache.java:460)
> at org.infinispan.cache.impl.EncoderCache.putAllAsync(EncoderCache.java:303)
> at org.infinispan.server.hotrod.CacheRequestProcessor.putAllInternal(CacheRequestProcessor.java:415)
> at org.infinispan.server.hotrod.CacheRequestProcessor.putAll(CacheRequestProcessor.java:410)
> at org.infinispan.server.hotrod.HotRodDecoder.switch3(HotRodDecoder.java:1836)
> at org.infinispan.server.hotrod.HotRodDecoder.switch1_0(HotRodDecoder.java:156)
> at org.infinispan.server.hotrod.HotRodDecoder.decode(HotRodDecoder.java:143)
> at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:505)
> at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:444)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:283)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
> at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
> at org.infinispan.server.core.transport.StatsChannelHandler.channelRead(StatsChannelHandler.java:26)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
> at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1421)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930)
> at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:794)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:424)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:326)
> at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
> at java.base/java.lang.Thread.run(Thread.java:834)
> {code}
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
6 years, 1 month
[JBoss JIRA] (ISPN-10760) nodejs-client fails when tries to use custom event converters
by Anna Manukyan (Jira)
[ https://issues.redhat.com/browse/ISPN-10760?page=com.atlassian.jira.plugi... ]
Anna Manukyan updated ISPN-10760:
---------------------------------
Summary: nodejs-client fails when tries to use custom event converters (was: nodejs-client fails when tries to use iterator, custom event converters, script execution)
> nodejs-client fails when tries to use custom event converters
> -------------------------------------------------------------
>
> Key: ISPN-10760
> URL: https://issues.redhat.com/browse/ISPN-10760
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 10.0.0.CR3
> Reporter: Anna Manukyan
> Assignee: Ryan Emerson
> Priority: Major
>
> When the nodejs-client connects to ServerNG and tries to use a custome event converter, or run iterator, the operation fails with exception:
> {code}
> 12:39:42,721 ERROR [org.infinispan.interceptors.impl.InvocationContextInterceptor] (SINGLE_PORT-ServerIO-5-13) ISPN000136: Error executing command PutMapCommand on Cache 'default', writing keys [WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\3\"\}, hashCode=1235679806}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\1\"\}, hashCode=1235677884}, WrappedByteArray{bytes=\{\"\k\"\:\"\j\l\o\c\a\l\-\i\t\2\"\}, hashCode=1235678845}]: org.infinispan.commons.dataconversion.EncodingException: ISPN000934: Unsupported content '[B@204b7b49'
> at org.infinispan.commons.dataconversion.BinaryTranscoder.transcode(BinaryTranscoder.java:67)
> at org.infinispan.encoding.DataConversion.convert(DataConversion.java:144)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.convertKey(CacheNotifierImpl.java:312)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.configureEvent(CacheNotifierImpl.java:515)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.doNotifyCreated(CacheNotifierImpl.java:406)
> at org.infinispan.notifications.cachelistener.CacheNotifierImpl.notifyCacheEntryCreated(CacheNotifierImpl.java:390)
> at org.infinispan.interceptors.impl.CallInterceptor.visitPutMapCommand(CallInterceptor.java:481)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.impl.CallInterceptor.visitCommand(CallInterceptor.java:166)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextThenApply(BaseAsyncInterceptor.java:81)
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.setSkipRemoteGetsAndInvokeNextForManyEntriesCommand(EntryWrappingInterceptor.java:658)
> at org.infinispan.interceptors.impl.EntryWrappingInterceptor.visitPutMapCommand(EntryWrappingInterceptor.java:412)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndFinally(BaseAsyncInterceptor.java:155)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.lambda$nonTxLockAndInvokeNext$3(AbstractLockingInterceptor.java:308)
> at org.infinispan.interceptors.SyncInvocationStage.andHandle(SyncInvocationStage.java:70)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.nonTxLockAndInvokeNext(AbstractLockingInterceptor.java:303)
> at org.infinispan.interceptors.locking.NonTransactionalLockingInterceptor.handleWriteManyCommand(NonTransactionalLockingInterceptor.java:65)
> at org.infinispan.interceptors.locking.AbstractLockingInterceptor.visitPutMapCommand(AbstractLockingInterceptor.java:182)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
> at org.infinispan.interceptors.impl.CacheMgmtInterceptor.visitPutMapCommand(CacheMgmtInterceptor.java:162)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNext(BaseAsyncInterceptor.java:59)
> at org.infinispan.interceptors.DDAsyncInterceptor.handleDefault(DDAsyncInterceptor.java:53)
> at org.infinispan.interceptors.DDAsyncInterceptor.visitPutMapCommand(DDAsyncInterceptor.java:89)
> at org.infinispan.commands.write.PutMapCommand.acceptVisitor(PutMapCommand.java:68)
> at org.infinispan.interceptors.BaseAsyncInterceptor.invokeNextAndExceptionally(BaseAsyncInterceptor.java:128)
> at org.infinispan.interceptors.impl.InvocationContextInterceptor.visitCommand(InvocationContextInterceptor.java:89)
> at org.infinispan.interceptors.impl.AsyncInterceptorChainImpl.invokeAsync(AsyncInterceptorChainImpl.java:226)
> at org.infinispan.cache.impl.CacheImpl.executeCommandAndCommitIfNeededAsync(CacheImpl.java:1847)
> at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1508)
> at org.infinispan.cache.impl.CacheImpl.putAllAsync(CacheImpl.java:1501)
> at org.infinispan.cache.impl.AbstractDelegatingAdvancedCache.putAllAsync(AbstractDelegatingAdvancedCache.java:460)
> at org.infinispan.cache.impl.EncoderCache.putAllAsync(EncoderCache.java:303)
> at org.infinispan.server.hotrod.CacheRequestProcessor.putAllInternal(CacheRequestProcessor.java:415)
> at org.infinispan.server.hotrod.CacheRequestProcessor.putAll(CacheRequestProcessor.java:410)
> at org.infinispan.server.hotrod.HotRodDecoder.switch3(HotRodDecoder.java:1836)
> at org.infinispan.server.hotrod.HotRodDecoder.switch1_0(HotRodDecoder.java:156)
> at org.infinispan.server.hotrod.HotRodDecoder.decode(HotRodDecoder.java:143)
> at io.netty.handler.codec.ByteToMessageDecoder.decodeRemovalReentryProtection(ByteToMessageDecoder.java:505)
> at io.netty.handler.codec.ByteToMessageDecoder.callDecode(ByteToMessageDecoder.java:444)
> at io.netty.handler.codec.ByteToMessageDecoder.channelRead(ByteToMessageDecoder.java:283)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
> at io.netty.channel.ChannelInboundHandlerAdapter.channelRead(ChannelInboundHandlerAdapter.java:93)
> at org.infinispan.server.core.transport.StatsChannelHandler.channelRead(StatsChannelHandler.java:26)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.AbstractChannelHandlerContext.fireChannelRead(AbstractChannelHandlerContext.java:352)
> at io.netty.channel.DefaultChannelPipeline$HeadContext.channelRead(DefaultChannelPipeline.java:1421)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:374)
> at io.netty.channel.AbstractChannelHandlerContext.invokeChannelRead(AbstractChannelHandlerContext.java:360)
> at io.netty.channel.DefaultChannelPipeline.fireChannelRead(DefaultChannelPipeline.java:930)
> at io.netty.channel.epoll.AbstractEpollStreamChannel$EpollStreamUnsafe.epollInReady(AbstractEpollStreamChannel.java:794)
> at io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:424)
> at io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:326)
> at io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
> at java.base/java.lang.Thread.run(Thread.java:834)
> {code}
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
6 years, 1 month
[JBoss JIRA] (ISPN-8628) Simplify QueryEngine handling of Broadcast vs Fetch queries
by Gustavo Fernandes (Jira)
[ https://issues.redhat.com/browse/ISPN-8628?page=com.atlassian.jira.plugin... ]
Gustavo Fernandes resolved ISPN-8628.
-------------------------------------
Resolution: Out of Date
> Simplify QueryEngine handling of Broadcast vs Fetch queries
> -----------------------------------------------------------
>
> Key: ISPN-8628
> URL: https://issues.redhat.com/browse/ISPN-8628
> Project: Infinispan
> Issue Type: Task
> Reporter: Gustavo Fernandes
> Assignee: Nistor Adrian
> Priority: Minor
>
> [~anistor] commented
> The existence of RemoteQueryDefinition and HsQueryRequest seems to be a symptom of misplaced responsibility. It all starts with QueryDefinition.initialize, which IMO should actually be placed inside QueryEngine, not QueryDefinition. Doing that refactoring will remove the need for RemoteQueryDefinition, which now exists just to differentiate between embedded and remote case, but that differentiation can be done inside the query engine itself. Also, HsQueryRequest is just a data holder that carries the return value of QueryEngine.createHsQuery. If QueryDefinition.initialize is moved to QueryEngine we would also not need this anymore.
> I did not think about it in detail but maybe we would also need to make QueryDefinition mutable for QueryEngine and immutable for external parties. In that case we can extract QueryDefinition as an immutable interface (exposing getters only) and it's implementation class could have package local setters accessible to QueryEngine only.
--
This message was sent by Atlassian Jira
(v7.13.8#713008)
6 years, 1 month