[JBoss JIRA] (ISPN-2817) Create a locate() API on the Java Hot Rod client
by Mircea Markus (JIRA)
[ https://issues.jboss.org/browse/ISPN-2817?page=com.atlassian.jira.plugin.... ]
Mircea Markus updated ISPN-2817:
--------------------------------
Status: Resolved (was: Pull Request Sent)
Resolution: Done
> Create a locate() API on the Java Hot Rod client
> ------------------------------------------------
>
> Key: ISPN-2817
> URL: https://issues.jboss.org/browse/ISPN-2817
> Project: Infinispan
> Issue Type: Feature Request
> Components: Distributed Cache
> Affects Versions: 5.2.1.Final
> Reporter: Mircea Markus
> Assignee: Manik Surtani
> Priority: Critical
> Fix For: 5.2.2.Final, 5.3.0.Final
>
>
> A locate() API to allow Java clients to make use of the consistent hash present in a RemoteCache instance and return a String representation of the endpoints assigned to a particular key. Typical signature:
> {code}
> List<String> locate(Object key)
> {code}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
13 years, 1 month
[JBoss JIRA] (ISPN-2785) CLI Codecs are incomplete
by RH Bugzilla Integration (JIRA)
[ https://issues.jboss.org/browse/ISPN-2785?page=com.atlassian.jira.plugin.... ]
RH Bugzilla Integration commented on ISPN-2785:
-----------------------------------------------
Vitalii Chepeliuk <vchepeli(a)redhat.com> made a comment on [bug 906271|https://bugzilla.redhat.com/show_bug.cgi?id=906271]
HotRod is OK, but memcached still has some problems with class cast
[remoting://localhost:9999/local/default]> cache memcachedCache
[remoting://localhost:9999/local/memcachedCache]> encoding memcached
[remoting://localhost:9999/local/memcachedCache]> put a a
[remoting://localhost:9999/local/memcachedCache]> get a
java.lang.String cannot be cast to org.infinispan.server.memcached.MemcachedValue
[remoting://localhost:9999/local/memcachedCache]> get a
java.lang.String cannot be cast to org.infinispan.server.memcached.MemcachedValue
[remoting://localhost:9999/local/memcachedCache]> get d
null
[remoting://localhost:9999/local/memcachedCache]> put a a
[remoting://localhost:9999/local/memcachedCache]> get a
java.lang.String cannot be cast to org.infinispan.server.memcached.MemcachedValue
###########################SERVER######################################
17:00:55,968 ERROR [org.infinispan.cli.interpreter.Interpreter] (pool-1-thread-1) ISPN019003: Interpreter error: java.lang.ClassCastException: java.lang.String cannot be cast to org.infinispan.server.memcached.MemcachedValue
at org.infinispan.cli.interpreter.codec.MemcachedCodec.decodeValue(MemcachedCodec.java:55) [infinispan-cli-server-5.2.1.Final-redhat-1.jar:5.2.1.Final-redhat-1]
at org.infinispan.cli.interpreter.statement.GetStatement.execute(GetStatement.java:77) [infinispan-cli-server-5.2.1.Final-redhat-1.jar:5.2.1.Final-redhat-1]
at org.infinispan.cli.interpreter.Interpreter.execute(Interpreter.java:161) [infinispan-cli-server-5.2.1.Final-redhat-1.jar:5.2.1.Final-redhat-1]
at sun.reflect.GeneratedMethodAccessor10.invoke(Unknown Source) [:1.7.0_11]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) [rt.jar:1.7.0_11]
at java.lang.reflect.Method.invoke(Method.java:601) [rt.jar:1.7.0_11]
at org.infinispan.jmx.ResourceDMBean.invoke(ResourceDMBean.java:275) [infinispan-core-5.2.1.Final-redhat-1.jar:5.2.1.Final-redhat-1]
at com.sun.jmx.interceptor.DefaultMBeanServerInterceptor.invoke(DefaultMBeanServerInterceptor.java:819) [rt.jar:1.7.0_11]
at com.sun.jmx.mbeanserver.JmxMBeanServer.invoke(JmxMBeanServer.java:791) [rt.jar:1.7.0_11]
at org.jboss.as.jmx.PluggableMBeanServerImpl$TcclMBeanServer.invoke(PluggableMBeanServerImpl.java:498) [jboss-as-jmx-7.1.3.Final-redhat-4.jar:7.1.3.Final-redhat-4]
at org.jboss.as.jmx.PluggableMBeanServerImpl.invoke(PluggableMBeanServerImpl.java:246) [jboss-as-jmx-7.1.3.Final-redhat-4.jar:7.1.3.Final-redhat-4]
at org.jboss.remotingjmx.protocol.v1.ServerProxy$InvokeHandler.handle(ServerProxy.java:1034)
at org.jboss.remotingjmx.protocol.v1.ServerProxy$MessageReciever$1.run(ServerProxy.java:215)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110) [rt.jar:1.7.0_11]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603) [rt.jar:1.7.0_11]
at java.lang.Thread.run(Thread.java:722) [rt.jar:1.7.0_11]
> CLI Codecs are incomplete
> -------------------------
>
> Key: ISPN-2785
> URL: https://issues.jboss.org/browse/ISPN-2785
> Project: Infinispan
> Issue Type: Bug
> Components: CLI
> Affects Versions: 5.2.0.Final
> Reporter: Tristan Tarrant
> Assignee: Tristan Tarrant
> Fix For: 5.3.0.Alpha1
>
>
> The Memcached and REST codecs do not do anything useful
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
13 years, 1 month
[JBoss JIRA] (ISPN-2773) Can't access a non-clustered cache via HotRod
by RH Bugzilla Integration (JIRA)
[ https://issues.jboss.org/browse/ISPN-2773?page=com.atlassian.jira.plugin.... ]
RH Bugzilla Integration commented on ISPN-2773:
-----------------------------------------------
Martin Gencur <mgencur(a)redhat.com> changed the Status of [bug 906008|https://bugzilla.redhat.com/show_bug.cgi?id=906008] from ON_QA to VERIFIED
> Can't access a non-clustered cache via HotRod
> ---------------------------------------------
>
> Key: ISPN-2773
> URL: https://issues.jboss.org/browse/ISPN-2773
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 5.2.0.CR3
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Blocker
> Fix For: 5.2.0.Final
>
>
> With the ISPN-2632 fix, we switched from using the JGroups view id as a HotRod topology id, to using the topology id of the cache being accessed.
> If the cache isn't clustered, however, it doesn't have a RpcManager and attempting to read the cache's topology id results in a NullPointerException:
> {noformat}
> java.lang.NullPointerException
> at org.infinispan.server.hotrod.AbstractEncoder1x.getTopologyResponse(AbstractEncoder1x.scala:160)
> at org.infinispan.server.hotrod.AbstractEncoder1x.writeHeader(AbstractEncoder1x.scala:49)
> at org.infinispan.server.hotrod.HotRodEncoder.encode(HotRodEncoder.scala:63)
> at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:66)
> at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
> at org.jboss.netty.channel.Channels.write(Channels.java:704)
> at org.jboss.netty.channel.Channels.write(Channels.java:671)
> at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:248)
> at org.infinispan.server.core.AbstractProtocolDecoder.writeResponse(AbstractProtocolDecoder.scala:179)
> at org.infinispan.server.hotrod.HotRodDecoder.customDecodeHeader(HotRodDecoder.scala:157)
> at org.infinispan.server.core.AbstractProtocolDecoder.decodeHeader(AbstractProtocolDecoder.scala:105)
> at org.infinispan.server.core.AbstractProtocolDecoder.decode(AbstractProtocolDecoder.scala:70)
> at org.infinispan.server.core.AbstractProtocolDecoder.decode(AbstractProtocolDecoder.scala:47)
> at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:500)
> at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
> at org.infinispan.server.core.AbstractProtocolDecoder.messageReceived(AbstractProtocolDecoder.scala:387)
> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
> at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
> at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:107)
> at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:313)
> at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:88)
> at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> {noformat}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
13 years, 1 month
[JBoss JIRA] (ISPN-2773) Can't access a non-clustered cache via HotRod
by RH Bugzilla Integration (JIRA)
[ https://issues.jboss.org/browse/ISPN-2773?page=com.atlassian.jira.plugin.... ]
RH Bugzilla Integration commented on ISPN-2773:
-----------------------------------------------
Martin Gencur <mgencur(a)redhat.com> made a comment on [bug 906008|https://bugzilla.redhat.com/show_bug.cgi?id=906008]
Verified by vchepeli.
> Can't access a non-clustered cache via HotRod
> ---------------------------------------------
>
> Key: ISPN-2773
> URL: https://issues.jboss.org/browse/ISPN-2773
> Project: Infinispan
> Issue Type: Bug
> Components: Server
> Affects Versions: 5.2.0.CR3
> Reporter: Dan Berindei
> Assignee: Dan Berindei
> Priority: Blocker
> Fix For: 5.2.0.Final
>
>
> With the ISPN-2632 fix, we switched from using the JGroups view id as a HotRod topology id, to using the topology id of the cache being accessed.
> If the cache isn't clustered, however, it doesn't have a RpcManager and attempting to read the cache's topology id results in a NullPointerException:
> {noformat}
> java.lang.NullPointerException
> at org.infinispan.server.hotrod.AbstractEncoder1x.getTopologyResponse(AbstractEncoder1x.scala:160)
> at org.infinispan.server.hotrod.AbstractEncoder1x.writeHeader(AbstractEncoder1x.scala:49)
> at org.infinispan.server.hotrod.HotRodEncoder.encode(HotRodEncoder.scala:63)
> at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.doEncode(OneToOneEncoder.java:66)
> at org.jboss.netty.handler.codec.oneone.OneToOneEncoder.handleDownstream(OneToOneEncoder.java:59)
> at org.jboss.netty.channel.Channels.write(Channels.java:704)
> at org.jboss.netty.channel.Channels.write(Channels.java:671)
> at org.jboss.netty.channel.AbstractChannel.write(AbstractChannel.java:248)
> at org.infinispan.server.core.AbstractProtocolDecoder.writeResponse(AbstractProtocolDecoder.scala:179)
> at org.infinispan.server.hotrod.HotRodDecoder.customDecodeHeader(HotRodDecoder.scala:157)
> at org.infinispan.server.core.AbstractProtocolDecoder.decodeHeader(AbstractProtocolDecoder.scala:105)
> at org.infinispan.server.core.AbstractProtocolDecoder.decode(AbstractProtocolDecoder.scala:70)
> at org.infinispan.server.core.AbstractProtocolDecoder.decode(AbstractProtocolDecoder.scala:47)
> at org.jboss.netty.handler.codec.replay.ReplayingDecoder.callDecode(ReplayingDecoder.java:500)
> at org.jboss.netty.handler.codec.replay.ReplayingDecoder.messageReceived(ReplayingDecoder.java:435)
> at org.infinispan.server.core.AbstractProtocolDecoder.messageReceived(AbstractProtocolDecoder.scala:387)
> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:268)
> at org.jboss.netty.channel.Channels.fireMessageReceived(Channels.java:255)
> at org.jboss.netty.channel.socket.nio.NioWorker.read(NioWorker.java:88)
> at org.jboss.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:107)
> at org.jboss.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:313)
> at org.jboss.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:88)
> at org.jboss.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178)
> at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
> at java.lang.Thread.run(Thread.java:662)
> {noformat}
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
13 years, 1 month
[JBoss JIRA] (ISPN-2835) Issues w/ M/R test cases if cache are not explicitly started on all nodes
by Anna Manukyan (JIRA)
[ https://issues.jboss.org/browse/ISPN-2835?page=com.atlassian.jira.plugin.... ]
Anna Manukyan commented on ISPN-2835:
-------------------------------------
In this case, your code - the createCacheManagers() method should look something like:
{code}
@Override
@Override
protected void createCacheManagers() throws Throwable {
ConfigurationBuilder builder = getDefaultClusteredCacheConfig(CacheMode.DIST_SYNC, true);
createCluster(builder, 4);
for(EmbeddedCacheManager obj : cacheManagers) {
((DefaultCacheManager) obj).startCache();
}
}
{code}
> Issues w/ M/R test cases if cache are not explicitly started on all nodes
> -------------------------------------------------------------------------
>
> Key: ISPN-2835
> URL: https://issues.jboss.org/browse/ISPN-2835
> Project: Infinispan
> Issue Type: Feature Request
> Components: Core API, Distributed Execution and Map/Reduce
> Reporter: Ray Tsang
> Assignee: Galder Zamarreño
> Fix For: 5.3.0.Alpha1, 5.3.0.Final
>
> Attachments: mr-test-src.zip
>
>
> I ran into some issues while using M/R. The gist of the issue I was seeing is that:
> Start a cluster of Embedded Caches, like 4 nodes
> Put in 100 elements
> Run a simple M/R job to count the number of keys
> If I run the M/R job using the node I'm inserting elements into as coordinator - the result is 100
> But if I run the M/R job using a different node as coordinator, the result is less than 100
> More interestingly, I can pause for 5 seconds and run the M/R jobs again, the results are always less than 100
> This behavior doens't occur if I explicitly run cacheManager.getCache() for each of the nodes...
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira
13 years, 1 month