You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@ignite.apache.org by "Maksim Timonin (Jira)" <ji...@apache.org> on 2021/10/11 16:58:00 UTC

[jira] [Created] (IGNITE-15728) Provide custom reducer for ScanQueryFallbackClosableIterator

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)