[jira] [Commented] (IGNITE-1374) Error org.apache.ignite.IgniteCheckedException: Failed to send response to node. Unsupported direct type during a cache iteration

2015-09-10 Thread Enrico Olivelli (JIRA) 

[ 
https://issues.apache.org/jira/browse/IGNITE-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14738835#comment-14738835
 ] 

Enrico Olivelli commented on IGNITE-1374:
-

I'm sorry, I cannot reproduce the problem. Next week I will try to revert my 
code to the original (buggy) version and deploy to the DEV environment, which 
is made of many clients and 2 servers









> 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
>Assignee: Anton Vinogradov
>Priority: Blocker
>  Labels: user-request
> Attachments: 1374.patch, QueryResponseTest.java
>
>
> Using ignite 1.3.0-incubating I get this error while issuing an iteration on 
> a cache
> {code}
>  Set keys = new HashSet<>();
> for (Iterator> 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)

[jira] [Commented] (IGNITE-1374) Error org.apache.ignite.IgniteCheckedException: Failed to send response to node. Unsupported direct type during a cache iteration

2015-09-09 Thread Enrico Olivelli (JIRA) 

[ 
https://issues.apache.org/jira/browse/IGNITE-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14736355#comment-14736355
 ] 

Enrico Olivelli commented on IGNITE-1374:
-

I think that the problem is related to the PeerClassLoadingEnabled option, IMHO 
using your testcase the classloader used by all the nodes is the same, or 
PeerClassLoading works anyway, creating a duplicate of the class ?



> 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
>Assignee: Anton Vinogradov
>Priority: Blocker
>  Labels: user-request
> Attachments: QueryResponseTest.java
>
>
> Using ignite 1.3.0-incubating I get this error while issuing an iteration on 
> a cache
> {code}
>  Set keys = new HashSet<>();
> for (Iterator> 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)

[jira] [Commented] (IGNITE-1374) Error org.apache.ignite.IgniteCheckedException: Failed to send response to node. Unsupported direct type during a cache iteration

2015-09-08 Thread Enrico Olivelli (JIRA) 

[ 
https://issues.apache.org/jira/browse/IGNITE-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14734363#comment-14734363
 ] 

Enrico Olivelli commented on IGNITE-1374:
-

I will try to reproduce, maybe I did an error doing copy

Working code (with PeerClassLoadingEnabled=false, and the KeyPrefixPredicate 
class deployed on all the nodes):

{code}
ScanQuery scan = new ScanQuery<>(new 
KeyPrefixPredicate(prefix));
Set keys = new HashSet<>();
try (QueryCursor> cursor = 
getCache().query(scan)) {
for (Cache.Entry entry : cursor) {
String key = entry.getKey();
if (key.startsWith(prefix)) { // inutile
String remaining = key.substring(prefixlenght);
keys.add(remaining);
}
}
return keys;
}

public class KeyPrefixPredicate implements IgniteBiPredicate, 
Serializable {

private static final long serialVersionUID = 1;
private final String prefix;

public KeyPrefixPredicate(String prefix) {
this.prefix = prefix;
}

@Override
public boolean apply(String e1, Object e2) {
return e1 != null && e1.startsWith(prefix);
}

}
{code}

Code with the error (PeerClassLoadingEnabled=true, using lambda expression):
{code}


  String prefix = "myprefix...";
ScanQuery scan = new ScanQuery<>((key, value) -> {
return key.startsWith(prefix);
});
Set keys = new HashSet<>();
try (QueryCursor> cursor = 
getCache().query(scan)) {
for (Cache.Entry entry : cursor) {
String key = entry.getKey();
if (key.startsWith(prefix)) { // redundant
String remaining = key.substring(prefixlenght);
keys.add(remaining);
}
}
return keys;
}
{code}

The error is not throw on the thead which execute the example but is printed on 
on system log (maybe System.err or System.out, not in a "logger"), maybe it 
could be a system wiade UncatchedExceptionHandler

> 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
>Assignee: Anton Vinogradov
>Priority: Blocker
>  Labels: user-request
>
> Using ignite 1.3.0-incubating I get this error while issuing an iteration on 
> a cache
> {code}
>  Set keys = new HashSet<>();
> for (Iterator> 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)

[jira] [Commented] (IGNITE-1374) Error org.apache.ignite.IgniteCheckedException: Failed to send response to node. Unsupported direct type during a cache iteration

2015-09-04 Thread Enrico Olivelli (JIRA) 

[ 
https://issues.apache.org/jira/browse/IGNITE-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14730701#comment-14730701
 ] 

Enrico Olivelli commented on IGNITE-1374:
-

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 keys = new HashSet<>();
> for (Iterator> 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)