[infinispan-issues] [JBoss JIRA] (ISPN-5126) DistributedExecutorService ignores unsuccessful responses

[Dan Berindei (JIRA)]

     [ https://issues.jboss.org/browse/ISPN-5126?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dan Berindei updated ISPN-5126:
-------------------------------
    Status: Open  (was: New)


> DistributedExecutorService ignores unsuccessful responses
> ---------------------------------------------------------
>
>                 Key: ISPN-5126
>                 URL: https://issues.jboss.org/browse/ISPN-5126
>             Project: Infinispan
>          Issue Type: Bug
>          Components: Core, Distributed Execution and Map/Reduce
>    Affects Versions: 7.1.0.Alpha1, 7.0.3.Final
>            Reporter: Dan Berindei
>            Priority: Critical
>              Labels: testsuite_stability
>
> I got a failure in {{DistributedExecutorFailureTest}} (master only) on my machine because the distributed executor ignores {{CacheNotFoundResponse}} responses:
> {noformat}
> 15:18:45,516 TRACE (transport-thread-NodeA-p30129-t4:) [CommandAwareRpcDispatcher] Response: CacheNotFoundResponse
> 15:18:45,516 TRACE (transport-thread-NodeA-p30129-t4:) [RpcManagerImpl] Response(s) to DistributedExecuteCommand [cache=null, keys=[], callable=org.infinispan.distexec.DistributedExecutorFailoverTest$SleepingSimpleCallable at 23a9b62a] is {NodeB-4305=CacheNotFoundResponse}
> 15:18:45,517 ERROR (testng-DistributedExecutorFailoverTest:) [UnitTestTestNGListener] Test testBasicTargetRemoteDistributedCallable(org.infinispan.distexec.DistributedExecutorFailoverTest) failed.
> java.lang.AssertionError: expected:<1> but was:<null>
> 	at org.testng.AssertJUnit.fail(AssertJUnit.java:59)
> 	at org.testng.AssertJUnit.failNotEquals(AssertJUnit.java:364)
> 	at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:80)
> 	at org.testng.AssertJUnit.assertEquals(AssertJUnit.java:88)
> 	at org.infinispan.distexec.DistributedExecutorFailoverTest.testBasicTargetRemoteDistributedCallable(DistributedExecutorFailoverTest.java:74)
> {noformat}
> {{RemoteDistributedTaskPart.retrieveResult()}} ignores any response that's not a {{SuccessfulResponse}} and returns {{null}}. It should throw an exception instead, so that the failover policy can retry it on another node.



--
This message was sent by Atlassian JIRA
(v6.3.11#6341)