Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
95 commits
Select commit Hold shift + click to select a range
31da616
WIP
anton-vinogradov Nov 18, 2025
9492376
WIP
anton-vinogradov Nov 18, 2025
a52a71c
WIP
anton-vinogradov Nov 18, 2025
bf4fc47
WIP
anton-vinogradov Nov 18, 2025
b2b9092
WIP
anton-vinogradov Nov 18, 2025
e33f606
WIP
anton-vinogradov Nov 19, 2025
d367510
WIP
anton-vinogradov Nov 19, 2025
dbc5475
WIP
anton-vinogradov Nov 19, 2025
509cf23
WIP
anton-vinogradov Nov 19, 2025
8a3cd3d
WIP
anton-vinogradov Nov 19, 2025
abc7b3e
WIP
anton-vinogradov Nov 19, 2025
eb4e7be
WIP
anton-vinogradov Nov 19, 2025
b0519c3
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Nov 20, 2025
04710f3
WIP
anton-vinogradov Nov 20, 2025
5c2817e
WIP
anton-vinogradov Nov 20, 2025
e16f6e8
WIP
anton-vinogradov Nov 20, 2025
85f67bf
WIP
anton-vinogradov Nov 20, 2025
2c249a0
WIP
anton-vinogradov Nov 20, 2025
1c72889
WIP
anton-vinogradov Nov 21, 2025
e0441ad
WIP
anton-vinogradov Nov 21, 2025
0189213
WIP
anton-vinogradov Nov 24, 2025
2a1810e
WIP
anton-vinogradov Nov 24, 2025
c5a6047
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Nov 24, 2025
8f6f028
WIP
anton-vinogradov Nov 25, 2025
211a52b
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Nov 25, 2025
8fb697a
WIP
anton-vinogradov Nov 25, 2025
790ecd5
WIP
anton-vinogradov Nov 25, 2025
d835543
WIP
anton-vinogradov Nov 26, 2025
c977447
WIP
anton-vinogradov Nov 26, 2025
772c3d3
WIP
anton-vinogradov Nov 26, 2025
8cd74c6
WIP
anton-vinogradov Nov 26, 2025
ac2a762
WIP
anton-vinogradov Nov 26, 2025
4a82bfb
WIP
anton-vinogradov Nov 26, 2025
5bc605d
WIP
anton-vinogradov Nov 26, 2025
ddf6701
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Nov 26, 2025
8e9c706
WIP
anton-vinogradov Nov 27, 2025
fc4051f
WIP
anton-vinogradov Nov 27, 2025
c40455f
WIP
anton-vinogradov Nov 27, 2025
fdd04eb
WIP
anton-vinogradov Nov 27, 2025
878ed9d
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Nov 27, 2025
089ab13
WIP
anton-vinogradov Nov 27, 2025
e83a227
WIP
anton-vinogradov Nov 27, 2025
75c73c1
WIP
anton-vinogradov Nov 27, 2025
908fa01
WIP
anton-vinogradov Nov 27, 2025
d2d4202
WIP
anton-vinogradov Nov 27, 2025
4297d15
WIP
anton-vinogradov Nov 28, 2025
3771a7c
WIP
anton-vinogradov Nov 28, 2025
271d2fc
WIP
anton-vinogradov Nov 28, 2025
56913ef
WIP
anton-vinogradov Nov 28, 2025
3be87f6
WIP
anton-vinogradov Nov 28, 2025
42ff4c7
WIP
anton-vinogradov Dec 1, 2025
b81fabe
WIP
anton-vinogradov Dec 1, 2025
3a88f21
WIP
anton-vinogradov Dec 1, 2025
5ba7753
WIP
anton-vinogradov Dec 1, 2025
02341b3
WIP
anton-vinogradov Dec 1, 2025
b9872aa
WIP
anton-vinogradov Dec 1, 2025
270dc39
WIP
anton-vinogradov Dec 1, 2025
5129948
WIP
anton-vinogradov Dec 1, 2025
f2defda
WIP
anton-vinogradov Dec 1, 2025
7db5da5
WIP
anton-vinogradov Dec 1, 2025
94143ad
WIP
anton-vinogradov Dec 1, 2025
4889784
WIP
anton-vinogradov Dec 1, 2025
e949d59
WIP
anton-vinogradov Dec 1, 2025
cbcab6b
WIP
anton-vinogradov Dec 1, 2025
8b29eb8
WIP
anton-vinogradov Dec 2, 2025
c0903a5
WIP
anton-vinogradov Dec 2, 2025
f6e5c85
WIP
anton-vinogradov Dec 2, 2025
f14abe9
WIP
anton-vinogradov Dec 2, 2025
dc91994
WIP
anton-vinogradov Dec 2, 2025
b8cda3c
WIP
anton-vinogradov Dec 2, 2025
f1a9aa5
WIP
anton-vinogradov Dec 2, 2025
c3d05ae
WIP
anton-vinogradov Dec 2, 2025
8b41e49
WIP
anton-vinogradov Dec 2, 2025
3adc19a
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Dec 10, 2025
174df6f
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Dec 10, 2025
126d0be
WIP
anton-vinogradov Dec 12, 2025
13704c5
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Dec 12, 2025
ebed582
WIP
anton-vinogradov Dec 12, 2025
776f906
WIP
anton-vinogradov Dec 16, 2025
af4bf93
WIP
anton-vinogradov Dec 16, 2025
3860481
WIP
anton-vinogradov Dec 16, 2025
67f6311
WIP
anton-vinogradov Dec 16, 2025
ac91b59
WIP
anton-vinogradov Dec 23, 2025
18ce7ae
WIP
anton-vinogradov Dec 24, 2025
3d7c702
WIP
anton-vinogradov Dec 24, 2025
c7e1ce3
WIP
anton-vinogradov Dec 24, 2025
429a37b
WIP
anton-vinogradov Dec 25, 2025
2387cef
Merge remote-tracking branch 'origin/master' into ignite-26584
anton-vinogradov Jan 13, 2026
52caab4
WIP
anton-vinogradov Jan 16, 2026
19e5b24
WIP
anton-vinogradov Jan 16, 2026
bacb350
WIP
anton-vinogradov Jan 19, 2026
042d7f7
WIP
anton-vinogradov Jan 19, 2026
8b39a92
WIP
anton-vinogradov Jan 19, 2026
9ab80cb
WIP
anton-vinogradov Jan 19, 2026
4763603
WIP
anton-vinogradov Jan 19, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@
import org.apache.ignite.internal.processors.cache.distributed.dht.atomic.GridNearAtomicAbstractUpdateRequest;
import org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionDemander.RebalanceFuture;
import org.apache.ignite.internal.processors.cache.distributed.dht.topology.GridDhtLocalPartition;
import org.apache.ignite.internal.processors.cache.distributed.dht.topology.GridDhtPartitionState;
import org.apache.ignite.internal.processors.cache.distributed.dht.topology.GridDhtPartitionTopology;
import org.apache.ignite.internal.util.future.GridCompoundFuture;
import org.apache.ignite.internal.util.future.GridFinishedFuture;
Expand Down Expand Up @@ -221,12 +222,14 @@ public boolean disableRebalancingCancellationOptimization() {
assert part != null;
assert part.id() == p;

GridDhtPartitionState state = part.state();

// Do not rebalance OWNING or LOST partitions.
if (part.state() == OWNING || part.state() == LOST)
if (state == OWNING || state == LOST)
continue;

// State should be switched to MOVING during PME.
if (part.state() != MOVING) {
if (state != MOVING) {
throw new AssertionError("Partition has invalid state for rebalance "
+ aff.topologyVersion() + " " + part);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -923,7 +923,7 @@ private Collection<ClusterNode> updateTopologyHistory(long topVer, @Nullable Tcp

Collection<ClusterNode> top = topHist.get(topVer);

assert top != null : "Failed to find topology history [msg=" + msg + ", hist=" + topHist + ']';
assert top != null : "Failed to find topology history [top=" + topVer + ", msg=" + msg + ", hist=" + topHist + ']';

return top;
}
Expand Down
Loading
Loading