You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Mirza Aliev (Jira)" <ji...@apache.org> on 2021/06/08 07:39:00 UTC
[jira] [Updated] (IGNITE-14828) No fallback to full rebalance after
exception on historical
[ https://issues.apache.org/jira/browse/IGNITE-14828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Mirza Aliev updated IGNITE-14828:
---------------------------------
Description:
We have noticed that in some cases when we handle demand message in {{GridDhtPartitionSupplier.java}} it is possible for some reasons that
{code:java}
iter = grp.offheap().rebalanceIterator(demandMsg.partitions(), demandMsg.topologyVersion());
{code}
throw an exception. In that case, rebalance should switch to full, but the code has a bug and {{remainingParts}} has been filed after rebalance iterator has been created
{code:java}
for (int i = 0; i < histMap.size(); i++) {
int p = histMap.partitionAt(i);
remainingParts.add(p);
}
{code}
That means that we lost partitions that meant to be rebalanced by historical rebalance.
was:Will be filled soon
> No fallback to full rebalance after exception on historical
> -----------------------------------------------------------
>
> Key: IGNITE-14828
> URL: https://issues.apache.org/jira/browse/IGNITE-14828
> Project: Ignite
> Issue Type: Bug
> Reporter: Mirza Aliev
> Assignee: Mirza Aliev
> Priority: Major
> Time Spent: 10m
> Remaining Estimate: 0h
>
> We have noticed that in some cases when we handle demand message in {{GridDhtPartitionSupplier.java}} it is possible for some reasons that
> {code:java}
> iter = grp.offheap().rebalanceIterator(demandMsg.partitions(), demandMsg.topologyVersion());
> {code}
> throw an exception. In that case, rebalance should switch to full, but the code has a bug and {{remainingParts}} has been filed after rebalance iterator has been created
> {code:java}
> for (int i = 0; i < histMap.size(); i++) {
> int p = histMap.partitionAt(i);
> remainingParts.add(p);
> }
> {code}
> That means that we lost partitions that meant to be rebalanced by historical rebalance.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)