Maksim Timonin created IGNITE-15728:
---------------------------------------

             Summary: Provide custom reducer for 
ScanQueryFallbackClosableIterator
                 Key: IGNITE-15728
                 URL: https://issues.apache.org/jira/browse/IGNITE-15728
             Project: Ignite
          Issue Type: New Feature
            Reporter: Maksim Timonin
            Assignee: Maksim Timonin


ScanQueryFallbackClosableIterator

`awaitFirstItemAvailable` is invoked in this iterator, but it runs for single 
node only and it looks like it can be replaced with just reducer.hasNext() that 
awaits future.

Also there is some logic for retries. By commits history this is some 
ignite-spark related staff.

Investigate and fix. Because it's a single place where 
`CacheQueryReducer#awaitFirstItemAvailable` is used, and we could simplify code 
of reducer. 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to