You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/10/15 15:01:16 UTC
[1/2] ignite git commit: Log information about lost partitions.
Repository: ignite
Updated Branches:
refs/heads/master 51a202a4c -> 0f432e3fe
Log information about lost partitions.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/91d77a79
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/91d77a79
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/91d77a79
Branch: refs/heads/master
Commit: 91d77a79c4805e501d8637fc1263866d5e914fba
Parents: 7e547b1
Author: sboikov <sb...@apache.org>
Authored: Mon Oct 15 17:58:59 2018 +0300
Committer: sboikov <sb...@apache.org>
Committed: Mon Oct 15 17:58:59 2018 +0300
----------------------------------------------------------------------
.../distributed/dht/topology/GridDhtPartitionTopologyImpl.java | 6 ++++++
1 file changed, 6 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/91d77a79/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java
index 8b5c028..94bb7f1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java
@@ -2051,6 +2051,12 @@ public class GridDhtPartitionTopologyImpl implements GridDhtPartitionTopology {
}
}
+ if (!recentlyLost.isEmpty()) {
+ U.warn(log, "Detected lost partitions [grp=" + grp.cacheOrGroupName()
+ + ", parts=" + S.compact(recentlyLost)
+ + ", plc=" + plc + "]");
+ }
+
// Update partition state on all nodes.
for (Integer part : lost) {
long updSeq = updateSeq.incrementAndGet();
[2/2] ignite git commit: Merge remote-tracking branch 'origin/master'
Posted by sb...@apache.org.
Merge remote-tracking branch 'origin/master'
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0f432e3f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0f432e3f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0f432e3f
Branch: refs/heads/master
Commit: 0f432e3fee5c50f8f699b6a0bae1afc4f435f763
Parents: 91d77a7 51a202a
Author: sboikov <sb...@apache.org>
Authored: Mon Oct 15 17:59:37 2018 +0300
Committer: sboikov <sb...@apache.org>
Committed: Mon Oct 15 17:59:37 2018 +0300
----------------------------------------------------------------------
.../apache/ignite/IgniteSystemProperties.java | 6 +-
.../processors/cache/CacheGroupContext.java | 8 +
.../processors/cache/GridCacheEntryEx.java | 25 +-
.../processors/cache/GridCacheMapEntry.java | 202 ++++++-----
.../cache/GridCacheMvccEntryInfo.java | 5 -
.../processors/cache/GridCacheProcessor.java | 14 +-
.../cache/GridCacheSharedContext.java | 24 +-
.../cache/GridCacheUpdateTxResult.java | 51 +++
.../cache/IgniteCacheOffheapManager.java | 20 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 11 +
.../GridDistributedTxRemoteAdapter.java | 16 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 3 +-
.../dht/GridDhtTxAbstractEnlistFuture.java | 8 +
.../cache/distributed/dht/GridDhtTxRemote.java | 149 --------
.../near/GridNearTxAbstractEnlistFuture.java | 7 +-
.../near/GridNearTxEnlistFuture.java | 7 +-
.../cache/distributed/near/GridNearTxLocal.java | 2 +-
.../near/GridNearTxQueryEnlistFuture.java | 4 +
.../GridNearTxQueryResultsEnlistFuture.java | 7 +-
.../processors/cache/dr/GridCacheDrManager.java | 31 --
.../cache/dr/GridOsCacheDrManager.java | 13 -
.../cache/mvcc/MvccCachingManager.java | 341 +++++++++++++++++++
.../cache/mvcc/MvccProcessorImpl.java | 8 +-
.../processors/cache/mvcc/MvccTxEntry.java | 203 +++++++++++
.../cache/mvcc/MvccUpdateVersionAware.java | 5 -
.../processors/cache/mvcc/MvccUtils.java | 11 +
.../cache/persistence/CacheDataRowAdapter.java | 5 -
.../persistence/GridCacheOffheapManager.java | 15 +-
.../cache/persistence/tree/io/DataPageIO.java | 15 +-
.../wal/reader/IgniteWalIteratorFactory.java | 2 +-
.../continuous/CacheContinuousQueryManager.java | 18 +-
.../cache/transactions/IgniteTxAdapter.java | 27 --
.../cache/transactions/IgniteTxHandler.java | 171 +++++++++-
.../transactions/IgniteTxLocalAdapter.java | 10 +-
.../cache/tree/mvcc/data/MvccDataRow.java | 64 ++--
.../cache/tree/mvcc/data/MvccUpdateDataRow.java | 98 ++++--
.../cache/tree/mvcc/data/MvccUpdateResult.java | 16 +-
.../continuous/GridContinuousProcessor.java | 10 +-
.../processors/cache/GridCacheTestEntryEx.java | 11 +-
.../wal/IgniteWalIteratorSwitchSegmentTest.java | 3 +-
.../pagemem/BPlusTreePageMemoryImplTest.java | 1 +
.../BPlusTreeReuseListPageMemoryImplTest.java | 1 +
.../pagemem/IndexStoragePageMemoryImplTest.java | 1 +
.../pagemem/PageMemoryImplNoLoadTest.java | 1 +
.../persistence/pagemem/PageMemoryImplTest.java | 1 +
.../continuous/CacheContinuousBatchAckTest.java | 51 +++
...eContinuousQueryAsyncFilterListenerTest.java | 165 +++++++--
...nuousQueryConcurrentPartitionUpdateTest.java | 110 +++++-
...acheContinuousQueryExecuteInPrimaryTest.java | 33 ++
...usQueryFactoryFilterRandomOperationTest.java | 58 ++--
.../CacheContinuousQueryLostPartitionTest.java | 24 +-
...ontinuousQueryOperationFromCallbackTest.java | 205 ++++++++---
.../CacheContinuousQueryOperationP2PTest.java | 48 +++
.../CacheContinuousQueryOrderingEventTest.java | 137 ++++++--
...acheContinuousQueryRandomOperationsTest.java | 271 +++++++++++++--
...inuousWithTransformerReplicatedSelfTest.java | 9 +
...CacheKeepBinaryIterationNearEnabledTest.java | 9 +
...acheKeepBinaryIterationStoreEnabledTest.java | 10 +
.../CacheKeepBinaryIterationTest.java | 26 ++
.../ClientReconnectContinuousQueryTest.java | 14 +
...ridCacheContinuousQueryAbstractSelfTest.java | 109 +++---
.../GridCacheContinuousQueryConcurrentTest.java | 65 +++-
...eContinuousQueryMultiNodesFilteringTest.java | 10 +-
...eContinuousQueryReplicatedTxOneNodeTest.java | 15 +-
...niteCacheContinuousQueryBackupQueueTest.java | 8 +
.../IgniteCacheContinuousQueryClientTest.java | 10 +-
...eCacheContinuousQueryImmutableEntryTest.java | 10 +-
.../database/CacheFreeListImplSelfTest.java | 5 -
.../loadtests/hashmap/GridCacheTestContext.java | 1 +
.../processors/query/h2/opt/GridH2Row.java | 5 -
...acheMvccAbstractContinuousQuerySelfTest.java | 63 ++++
...eMvccAbstractSqlContinuousQuerySelfTest.java | 40 +++
.../mvcc/CacheMvccBasicContinuousQueryTest.java | 230 +++++++++++++
...eMvccClientReconnectContinuousQueryTest.java | 30 ++
...CacheMvccContinuousQueryBackupQueueTest.java | 30 ++
...eMvccContinuousQueryClientReconnectTest.java | 32 ++
.../CacheMvccContinuousQueryClientTest.java | 30 ++
...heMvccContinuousQueryImmutableEntryTest.java | 30 ++
...cContinuousQueryMultiNodesFilteringTest.java | 30 ++
...eMvccContinuousQueryPartitionedSelfTest.java | 29 ++
...ContinuousQueryPartitionedTxOneNodeTest.java | 36 ++
...heMvccContinuousQueryReplicatedSelfTest.java | 29 ++
...cContinuousQueryReplicatedTxOneNodeTest.java | 37 ++
...ContinuousWithTransformerClientSelfTest.java | 35 ++
...nuousWithTransformerPartitionedSelfTest.java | 42 +++
...inuousWithTransformerReplicatedSelfTest.java | 36 ++
...ccSqlContinuousQueryPartitionedSelfTest.java | 30 ++
...vccSqlContinuousQueryReplicatedSelfTest.java | 29 ++
.../testsuites/IgniteCacheMvccSqlTestSuite.java | 40 ++-
.../IgniteCacheQuerySelfTestSuite3.java | 15 +-
90 files changed, 3260 insertions(+), 672 deletions(-)
----------------------------------------------------------------------