[
https://issues.apache.org/jira/browse/IGNITE-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730701#comment-14730701
]
Enrico Olivelli edited comment on IGNITE-1374 at 9/4/15 2:40 PM:
-----------------------------------------------------------------
I have 2 server nodes (hosted in JVM process, not lanunched from the command
line), on servers no error is reported on logs
The error is on a ClientMode = true node
if I set PeerClassLoadingEnabled(false) and use a ScanQuery with a class
(KeyPrefixPredicate) deployed on servers the problem does not occour
{code}
ScanQuery<String, Object> scan = new ScanQuery<>(new
KeyPrefixPredicate(prefix));
Set<String> keys = new HashSet<>();
try (QueryCursor<Cache.Entry<String, Object>> cursor =
getCache().query(scan)) {
for (Cache.Entry<String, Object> entry : cursor) {
String key = entry.getKey();
if (key.startsWith(prefix)) { // inutile
String remaining = key.substring(prefixlenght);
keys.add(remaining);
}
}
return keys;
}
{code}
was (Author: eolivelli):
I have 2 server nodes (hosted in JVM process, not lanunched from the command
line), on servers no error is reported on logs
The error is on a ClientMode = true node
> Error org.apache.ignite.IgniteCheckedException: Failed to send response to
> node. Unsupported direct type during a cache iteration
> ---------------------------------------------------------------------------------------------------------------------------------
>
> Key: IGNITE-1374
> URL: https://issues.apache.org/jira/browse/IGNITE-1374
> Project: Ignite
> Issue Type: Bug
> Components: cache
> Reporter: Enrico Olivelli
> Priority: Blocker
>
> Using ignite 1.3.0-incubating I get this error while issuing an iteration on
> a cache
> {code}
> Set<String> keys = new HashSet<>();
> for (Iterator<Cache.Entry<String, Object>> it = cache.iterator();
> it.hasNext();) {
> String key = it.next().getKey();
> if (key.startsWith(prefix)) {
> keys.add(remaining);
> }
> }
> {code}
> This is the error
> {code}
> GRAVE: Failed to process message
> [senderId=a9548f63-2ac4-4600-a593-dfcdca71aa38, messageType=class
> o.a.i.i.processors.cache.query.GridCacheQueryResponse]
> class org.apache.ignite.IgniteCheckedException: Failed to send response to
> node. Unsupported direct type [message=GridCacheQueryResponse
> [finished=false, reqId=934, err=null, fields=false, metadata=null]]
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.processFailedMessage(GridCacheIoManager.java:507)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.onMessage0(GridCacheIoManager.java:232)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager.access$700(GridCacheIoManager.java:48)
> at
> org.apache.ignite.internal.processors.cache.GridCacheIoManager$OrderedMessageListener.onMessage(GridCacheIoManager.java:1018)
> at
> org.apache.ignite.internal.managers.communication.GridIoManager$GridCommunicationMessageSet.unwind(GridIoManager.java:2086)
> at
> org.apache.ignite.internal.managers.communication.GridIoManager.unwindMessageSet(GridIoManager.java:942)
> at
> org.apache.ignite.internal.managers.communication.GridIoManager.access$1700(GridIoManager.java:59)
> at
> org.apache.ignite.internal.managers.communication.GridIoManager$6.run(GridIoManager.java:911)
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
> at java.lang.Thread.run(Thread.java:745)
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
