[
https://issues.apache.org/jira/browse/IGNITE-500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15615236#comment-15615236
]
Anton Vinogradov edited comment on IGNITE-500 at 10/28/16 2:05 PM:
-------------------------------------------------------------------
Main fix point is to replace streaming by affinity to streaming by current
topology + affinity.
So, now all possible owners will gain update.
Also, improved remap feature, including throttle semaphore that is stops the
data handling while failed data processing. This fixes ExecutionTimeouts in
case of huge remaps.
Also, streamer now prints errors and throw exception on closing in case some
data can't be streamed properly. New data can't be handled now by streamer in
case some previous data streaming failed.
Fixed some minor bugs, related to this issue or not
Added and refactored tests.
Semen,
I've prepared code, please review.
was (Author: avinogradov):
Main fix point is to replace streaming by affinity to streaming by current
topology + affinity.
So, now all possible owners will gain update.
Also, improved remap feature, including throttle semaphore that is stops the
data handling while failed data processing.
Also, streamer now prints errors and throw exception on closing in case some
data can't be streamed properly. New data can't be handled now by streamer in
case some previous data streaming failed.
Fixed some minor bugs, related to this issue or not
Added and refactored tests.
Semen,
I've prepared code, please review.
> CacheLoadingConcurrentGridStartSelfTest fails
> ---------------------------------------------
>
> Key: IGNITE-500
> URL: https://issues.apache.org/jira/browse/IGNITE-500
> Project: Ignite
> Issue Type: Sub-task
> Reporter: Yakov Zhdanov
> Assignee: Anton Vinogradov
> Priority: Critical
> Labels: Muted_test, important, user-request
> Fix For: 1.8
>
> Attachments: ignite-500.log
>
>
> http://apacheignite.readme.io/v1.0/discuss/550865a8e35e9c3b0083af3e
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
