This is an automated email from the ASF dual-hosted git repository.
nizhikov pushed a change to branch ignite-cdc
in repository https://gitbox.apache.org/repos/asf/ignite.git.
from 16bea82 Revert "IGNITE-14353 Ability to specify postfix for
IgniteLogger instead of nodeId (#8923)"
add 4928ca5 IGNITE-14131 IgniteCompute tasks with same name, running from
one node and different ClassLoaders can lead to OOM - Fixes #9020.
add e2fa709 IGNITE-14684 Fixed node fail due to deleting
DurableBackgroundTask's at the end of a checkpoint when stopping a node (#9091)
add 29cd623 IGNITE-14469 Additional tests for control utility command
indexes_force_rebuild - Fixes #9061.
add 6b4ed99 IGNITE-14490 Test for scenario where cache.invoke() triggers
failure handler - Fixes #8976.
add 17ca570 IGNITE-14675 Refactors IgniteAuthenticationProcessor
callbacks. (#9079)
add 3109b31 IGNITE-13805 Add cache groups snapshot restore on the same
topology (#8648)
add 6c8cfbc IGNITE-14572 Include metastorage to snapshot (#9047)
add 626168e IGNITE-14729 Fix race condition in ClientImpl (#9102)
add cad0e8f IGNITE-14720 Remove suggestion about '-XX:+DisableExplicitGC'
option - Fixes #9096.
add b1529fb IGNITE-14714 LineLength checkstyle rule added (#9106)
add d181fbb Merge branch 'master' into ignite-cdc
No new revisions were added by this update.
Summary of changes:
checkstyle/checkstyle-suppressions.xml | 2 +
checkstyle/checkstyle.xml | 8 +
.../ml/clustering/KMeansClusterizationExample.java | 3 +-
.../dataset/AlgorithmSpecificDatasetExample.java | 22 +-
.../CatboostClassificationModelParserExample.java | 3 +-
.../KMeansClusterizationExportImportExample.java | 3 +-
.../modelparser/DecisionTreeFromSparkExample.java | 9 +-
.../DecisionTreeRegressionFromSparkExample.java | 9 +-
.../spark/modelparser/GBTFromSparkExample.java | 9 +-
.../modelparser/GBTRegressionFromSparkExample.java | 9 +-
.../spark/modelparser/KMeansFromSparkExample.java | 5 +-
.../LinearRegressionFromSparkExample.java | 8 +-
.../spark/modelparser/LogRegFromSparkExample.java | 9 +-
.../modelparser/RandomForestFromSparkExample.java | 9 +-
.../RandomForestRegressionFromSparkExample.java | 9 +-
.../spark/modelparser/SVMFromSparkExample.java | 5 +-
.../multiclass/OneVsRestClassificationExample.java | 7 +-
.../encoding/TargetEncoderExample.java | 4 +-
.../linear/BostonHousePricesPredictionExample.java | 3 +-
...gressionLSQRTrainerWithMinMaxScalerExample.java | 4 +-
...eeClassificationTrainerSQLInferenceExample.java | 4 +-
.../RandomForestClassificationExample.java | 4 +-
.../hyperparametertuning/Step_13_RandomSearch.java | 6 +-
.../Step_14_Parallel_Brute_Force_Search.java | 6 +-
.../Step_15_Parallel_Random_Search.java | 6 +-
.../Step_16_Genetic_Programming_Search.java | 6 +-
...tep_17_Parallel_Genetic_Programming_Search.java | 6 +-
.../ignite/examples/ml/util/MLSandboxDatasets.java | 9 +-
.../spark/JavaIgniteDataFrameJoinExample.java | 4 +-
idea/ignite_codeStyle.xml | 1 +
.../aop/aspectj/GridifySetToSetAspectJAspect.java | 3 +-
.../aspectj/GridifySetToValueAspectJAspect.java | 3 +-
.../gridify/aop/spring/GridifySpringEnhancer.java | 3 +-
.../GridDhtPartitionsStateValidatorBenchmark.java | 5 +-
.../cassandra/CassandraCacheStoreFactory.java | 5 +-
.../persistence/KeyValuePersistenceSettings.java | 15 +-
.../ignite/tests/IgnitePersistentStoreTest.java | 12 +-
.../apache/ignite/tests/utils/CassandraHelper.java | 3 +-
.../tests/persistence/blob/ignite-config.xml | 6 +-
.../tests/persistence/pojo/ignite-config.xml | 21 +-
.../tests/persistence/primitive/ignite-config.xml | 6 +-
.../client/ClientReconnectionSelfTest.java | 23 +-
.../internal/client/TaskSingleJobSplitAdapter.java | 3 +-
.../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 6 +-
.../jdbc2/JdbcDistributedJoinsQueryTest.java | 3 +-
.../internal/jdbc2/JdbcMetadataSelfTest.java | 3 +-
.../JdbcThinAuthenticateConnectionSelfTest.java | 8 +-
.../ignite/jdbc/thin/JdbcThinBatchSelfTest.java | 3 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 3 +-
.../qa/query/WarningOnBigQueryResultsBaseTest.java | 3 +-
.../persistence/FoldersReuseCompatibilityTest.java | 3 +-
.../internal/commandline/CommandHandler.java | 3 +-
.../cache/CacheIndexesForceRebuild.java | 9 +-
.../commandline/cache/CheckIndexInlineSizes.java | 4 +-
.../commandline/CommandHandlerParsingTest.java | 90 +-
...idCommandHandlerCheckIndexesInlineSizeTest.java | 6 +-
.../util/GridCommandHandlerClusterByClassTest.java | 3 +-
.../GridCommandHandlerIndexForceRebuildTest.java | 172 +++-
.../apache/ignite/util/GridCommandHandlerTest.java | 9 +-
.../src/main/java/org/apache/ignite/Ignite.java | 6 +-
.../main/java/org/apache/ignite/IgniteCompute.java | 4 +
.../java/org/apache/ignite/IgniteSnapshot.java | 14 +
.../org/apache/ignite/IgniteSystemProperties.java | 10 +-
.../cache/store/jdbc/CacheJdbcPojoStore.java | 7 +-
.../cache/store/jdbc/dialect/BasicJdbcDialect.java | 8 +-
.../cache/store/jdbc/dialect/DB2Dialect.java | 7 +-
.../cache/store/jdbc/dialect/SQLServerDialect.java | 7 +-
.../events/CacheConsistencyViolationEvent.java | 7 +-
.../ignite/events/CacheQueryExecutedEvent.java | 7 +-
.../apache/ignite/events/CacheQueryReadEvent.java | 7 +-
.../org/apache/ignite/events/CheckpointEvent.java | 7 +-
.../org/apache/ignite/events/DeploymentEvent.java | 7 +-
.../org/apache/ignite/events/DiscoveryEvent.java | 7 +-
.../main/java/org/apache/ignite/events/Event.java | 4 +-
.../ignite/events/SqlQueryExecutionEvent.java | 7 +-
.../java/org/apache/ignite/events/TaskEvent.java | 7 +-
.../ignite/internal/GridJobExecuteRequest.java | 6 +-
.../apache/ignite/internal/GridKernalContext.java | 2 +-
.../ignite/internal/GridKernalContextImpl.java | 2 +-
.../org/apache/ignite/internal/IgniteFeatures.java | 5 +-
.../org/apache/ignite/internal/IgniteKernal.java | 4 +-
.../org/apache/ignite/internal/IgnitionEx.java | 11 +-
.../apache/ignite/internal/binary/BinaryUtils.java | 13 +-
.../binary/streams/BinaryMemoryAllocator.java | 3 +-
.../query/index/sorted/inline/InlineIndexImpl.java | 9 +-
.../client/thin/IgniteClientFutureImpl.java | 54 +-
.../ignite/internal/cluster/IgniteClusterImpl.java | 7 +-
.../internal/jdbc/thin/JdbcThinConnection.java | 6 +-
.../internal/managers/GridManagerAdapter.java | 8 +-
.../deployment/GridDeploymentLocalStore.java | 174 ++--
.../deployment/GridDeploymentPerLoaderStore.java | 2 +-
.../managers/discovery/GridDiscoveryManager.java | 31 +-
.../managers/encryption/GridEncryptionManager.java | 3 +-
.../internal/metric/IoStatisticsHolderQuery.java | 3 +-
.../ignite/internal/pagemem/PageIdAllocator.java | 6 -
.../pagemem/store/IgnitePageStoreManager.java | 8 +-
.../internal/pagemem/wal/record/DataEntry.java | 5 +-
.../internal/pagemem/wal/record/WALRecord.java | 3 +-
.../delta/MetaPageUpdatePartitionDataRecordV2.java | 9 +-
.../internal/processors/GridProcessorAdapter.java | 5 +-
.../affinity/GridAffinityAssignmentCache.java | 4 +-
.../processors/affinity/GridAffinityProcessor.java | 29 +-
.../IgniteAuthenticationProcessor.java | 27 +-
.../processors/cache/CacheGroupMetricsImpl.java | 3 +-
.../internal/processors/cache/CacheLazyEntry.java | 19 +-
.../processors/cache/CacheMetricsImpl.java | 7 +-
.../processors/cache/ClusterCachesInfo.java | 44 +-
.../internal/processors/cache/ExchangeActions.java | 24 +
.../cache/GatewayProtectedCacheProxy.java | 56 +-
.../processors/cache/GridCacheAdapter.java | 6 +-
.../processors/cache/GridCacheIoManager.java | 13 +-
.../processors/cache/GridCacheMapEntry.java | 7 +-
.../cache/GridCachePartitionExchangeManager.java | 10 +-
.../processors/cache/GridCacheProcessor.java | 23 +-
.../processors/cache/GridCacheSharedContext.java | 2 +
.../cache/ValidationOnNodeJoinUtils.java | 4 +-
.../cache/binary/BinaryMetadataTransport.java | 3 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 38 +
.../distributed/dht/atomic/GridDhtAtomicCache.java | 6 +-
.../dht/colocated/GridDhtColocatedCache.java | 6 +-
.../dht/colocated/GridDhtColocatedLockFuture.java | 3 +-
.../dht/colocated/GridDhtDetachedCacheEntry.java | 10 +-
.../dht/preloader/GridDhtPartitionFullMap.java | 3 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 35 +-
.../dht/preloader/GridDhtPreloader.java | 4 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 6 +-
.../distributed/near/GridNearAtomicCache.java | 3 +-
...dNearOptimisticSerializableTxPrepareFuture.java | 18 +-
.../near/GridNearOptimisticTxPrepareFuture.java | 3 +-
.../cache/distributed/near/GridNearTxLocal.java | 70 +-
.../processors/cache/mvcc/MvccProcessorImpl.java | 3 +-
.../internal/processors/cache/mvcc/MvccUtils.java | 4 +-
.../internal/processors/cache/package-info.java | 5 +-
.../GridCacheDatabaseSharedManager.java | 6 +-
.../cache/persistence/GridCacheOffheapManager.java | 8 +-
.../checkpoint/CheckpointPagesWriter.java | 3 +-
.../persistence/checkpoint/CheckpointWorkflow.java | 3 +-
.../CachePartitionDefragmentationManager.java | 6 +-
.../cache/persistence/defragmentation/LinkMap.java | 16 +-
.../persistence/file/FilePageStoreManager.java | 82 +-
.../file/FileVersionCheckingFactory.java | 4 +-
.../cache/persistence/freelist/PagesList.java | 3 +-
.../cache/persistence/metastorage/MetaStorage.java | 29 +-
.../metastorage/MetastorageRowStoreEntry.java | 3 +-
.../processors/cache/persistence/package-info.java | 5 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 7 +-
.../pagemem/PageReadWriteManagerImpl.java | 8 +-
.../cache/persistence/pagemem/package-info.java | 5 +-
.../snapshot/IgniteCacheSnapshotManager.java | 3 +-
.../snapshot/IgniteSnapshotManager.java | 336 +++++---
.../persistence/snapshot/SnapshotFutureTask.java | 191 +++--
.../snapshot/SnapshotOperationRequest.java | 130 +++
.../snapshot/SnapshotPartitionsVerifyTask.java | 8 +
.../snapshot/SnapshotRestoreProcess.java | 935 +++++++++++++++++++++
.../cache/persistence/tree/BPlusTree.java | 3 +-
.../persistence/tree/io/AbstractDataPageIO.java | 3 +-
.../cache/persistence/tree/io/PageIO.java | 3 +-
.../cache/persistence/tree/util/PageHandler.java | 16 +-
.../wal/reader/StandaloneGridKernalContext.java | 2 +-
.../wal/reader/StandaloneWalRecordsIterator.java | 6 +-
.../wal/serializer/RecordV1Serializer.java | 8 +-
.../cache/query/GridCacheQueryManager.java | 17 +-
.../cache/transactions/IgniteTxHandler.java | 5 +-
.../cache/transactions/IgniteTxManager.java | 6 +-
.../processors/cache/tree/CacheDataRowStore.java | 10 +-
.../cache/tree/mvcc/data/MvccUpdateDataRow.java | 6 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 10 +
.../cluster/ClusterMetricsUpdateMessage.java | 6 +-
.../cluster/GridClusterStateProcessor.java | 8 +-
.../datastreamer/DataStreamerRequest.java | 6 +-
.../datastructures/DataStructuresProcessor.java | 36 +-
.../GridCacheAtomicReferenceImpl.java | 4 +-
.../localtask/DurableBackgroundTasksProcessor.java | 103 ++-
.../marshaller/MarshallerMappingTransport.java | 5 +-
.../persistence/DistributedMetaStorageImpl.java | 110 ++-
.../persistence/DmsDataWriterWorker.java | 233 ++---
.../metastorage/persistence/DmsWorkerStatus.java | 30 -
.../processors/offheap/GridOffHeapProcessor.java | 7 +-
.../ignite/internal/processors/package-info.java | 4 +-
.../processors/platform/PlatformProcessorImpl.java | 6 +-
.../platform/client/ClientConnectionContext.java | 8 +-
.../transactions/PlatformTransactions.java | 6 +-
.../processors/query/GridQueryProcessor.java | 8 +-
.../handlers/probe/GridProbeCommandHandler.java | 6 +-
.../processors/security/SecurityUtils.java | 12 -
.../GridInternalSubscriptionProcessor.java | 3 +-
.../GridTracingConfigurationManager.java | 8 +-
.../suggestions/JvmConfigurationSuggestions.java | 6 -
.../apache/ignite/internal/util/GridUnsafe.java | 7 +-
.../apache/ignite/internal/util/IgniteUtils.java | 36 +-
.../util/distributed/DistributedProcess.java | 17 +-
.../util/tostring/GridToStringBuilder.java | 7 +-
.../apache/ignite/internal/util/typedef/CIX1.java | 7 +-
.../apache/ignite/internal/util/typedef/CIX2.java | 7 +-
.../apache/ignite/internal/util/typedef/COX.java | 7 +-
.../apache/ignite/internal/util/typedef/CX1.java | 7 +-
.../apache/ignite/internal/util/typedef/CX2.java | 7 +-
.../apache/ignite/internal/util/typedef/PX1.java | 7 +-
.../apache/ignite/internal/util/typedef/PX2.java | 7 +-
.../apache/ignite/internal/util/typedef/R2.java | 7 +-
.../apache/ignite/internal/util/typedef/R3.java | 7 +-
.../apache/ignite/internal/util/typedef/RX1.java | 7 +-
.../apache/ignite/internal/util/typedef/RX2.java | 7 +-
.../apache/ignite/internal/util/typedef/RX3.java | 7 +-
.../ignite/internal/util/worker/GridWorker.java | 4 +-
...VisorFindAndDeleteGarbageInPersistenceTask.java | 17 +-
.../visor/cache/index/IndexForceRebuildTask.java | 135 +--
.../visor/cache/index/IndexRebuildStatusTask.java | 5 +-
.../node/VisorCacheRebalanceCollectorTask.java | 3 +-
.../query/VisorRunningQueriesCollectorTask.java | 4 +-
.../VisorTracingConfigurationTask.java | 3 +-
.../ignite/internal/visor/util/VisorMimeTypes.java | 9 +-
.../ignite/mxbean/DataRegionMetricsMXBean.java | 4 +-
.../ignite/mxbean/DefragmentationMXBean.java | 4 +-
.../ignite/spi/checkpoint/CheckpointSpi.java | 8 +-
.../jobstealing/JobStealingCollisionSpi.java | 4 +-
.../spi/communication/tcp/TcpCommunicationSpi.java | 9 +-
.../tcp/internal/CommunicationWorker.java | 4 +-
.../tcp/internal/ConnectionClientPool.java | 27 +-
.../tcp/internal/GridNioServerWrapper.java | 3 +-
.../TcpCommunicationConfigInitializer.java | 3 +-
.../TcpCommunicationConnectionCheckFuture.java | 3 +-
.../spi/deployment/local/LocalDeploymentSpi.java | 100 ++-
.../ignite/spi/discovery/tcp/ClientImpl.java | 4 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 3 +-
.../spi/discovery/tcp/TcpDiscoverySpiMBean.java | 3 +-
.../multicast/TcpDiscoveryMulticastIpFinder.java | 4 +-
.../apache/ignite/spi/failover/FailoverSpi.java | 3 +-
.../jobstealing/JobStealingFailoverSpi.java | 6 +-
.../view/datastructures/ReentrantLockView.java | 3 +-
.../view/datastructures/SemaphoreView.java | 3 +-
...nerRWThroughDisabledTransactionalCacheTest.java | 3 +-
...CacheStoreSessionListenerLifecycleSelfTest.java | 5 +-
...hallerStoreKeepBinaryWithSqlEscapeSelfTest.java | 3 +-
.../cache/store/jdbc/CacheJdbcPojoStoreTest.java | 6 +-
.../jdbc/JdbcTypesDefaultTransformerTest.java | 7 +-
.../TestJdbcPojoStoreFactoryWithHangWriteAll.java | 7 +-
.../internal/ClusterNodeMetricsSelfTest.java | 5 +-
.../internal/GridContinuousTaskSelfTest.java | 6 +-
.../internal/GridJobMasterLeaveAwareSelfTest.java | 3 +-
.../GridMultipleVersionsDeploymentSelfTest.java | 2 +-
.../ignite/internal/GridSpiExceptionSelfTest.java | 3 +-
.../ignite/internal/IgniteClientFailuresTest.java | 3 +-
.../IgniteExplicitImplicitDeploymentSelfTest.java | 178 ++--
.../RaceOnDeployClassesWithSameAliases.java | 147 ----
.../binary/BinaryClassLoaderMultiJvmTest.java | 3 +-
.../internal/binary/BinaryClassLoaderTest.java | 3 +-
.../BinaryObjectBuilderAdditionalSelfTest.java | 11 +-
.../BinaryObjectBuilderDefaultMappersSelfTest.java | 3 +-
.../inline/InlineIndexKeyTypeRegistryTest.java | 12 +-
...GridManagerMxBeanIllegalArgumentHandleTest.java | 4 +-
.../managers/IgniteDiagnosticMessagesTest.java | 5 +-
.../IgniteCommunicationBalanceTest.java | 3 +-
.../GridDeploymentManagerStopSelfTest.java | 4 +-
.../GridDifferentLocalDeploymentSelfTest.java | 162 ++++
.../P2PCacheOperationIntoComputeTest.java | 5 +-
.../wal/record/WALRecordSerializationTest.java | 3 +-
.../Authentication1kUsersNodeRestartTest.java | 20 +-
.../AuthenticationProcessorSelfTest.java | 85 +-
.../processors/cache/CacheMetricsManageTest.java | 6 +-
.../processors/cache/ClusterStateTestUtils.java | 5 +-
.../GridCacheConfigurationConsistencySelfTest.java | 3 +-
.../cache/GridCachePartitionedWritesTest.java | 4 +-
.../IgniteCacheClusterReadOnlyModeSelfTest.java | 6 +-
.../cache/IgniteClientCacheStartFailoverTest.java | 8 +-
.../cache/IgniteDynamicCacheStartSelfTest.java | 8 +-
...iteExchangeLatchManagerCoordinatorFailTest.java | 4 +-
.../IgniteSemaphoreAbstractSelfTest.java | 6 +-
.../GridCachePartitionedNodeRestartTxSelfTest.java | 5 +-
.../distributed/CacheBaselineTopologyTest.java | 8 +-
.../CacheClientsConcurrentStartTest.java | 30 +-
.../cache/distributed/CacheStartOnJoinTest.java | 7 +-
...PartitionEvictionDuringReadThroughSelfTest.java | 7 +-
...ridExchangeFreeCellularSwitchIsolationTest.java | 3 +-
.../IgniteCachePartitionLossPolicySelfTest.java | 4 +-
.../distributed/IgniteCacheSizeFailoverTest.java | 2 +-
...sabledAtomicOnheapMultiNodeFullApiSelfTest.java | 3 +-
.../GridCachePartitionsStateValidationTest.java | 25 +-
.../GridCachePartitionsStateValidatorSelfTest.java | 3 +-
.../dht/IgniteCacheStartWithLoadTest.java | 7 +-
.../dht/topology/BlockedEvictionsTest.java | 7 +-
...MovingPartitionIsEvictedDuringClearingTest.java | 7 +-
...reloadingRestartWhileClearingPartitionTest.java | 7 +-
.../GridCachePartitionedFilteredPutSelfTest.java | 3 +-
...isabledAtomicOnheapMultiJvmFullApiSelfTest.java | 3 +-
...dNearDisabledOnheapMultiJvmFullApiSelfTest.java | 3 +-
...heMvccAbstractBasicCoordinatorFailoverTest.java | 5 +-
.../cache/mvcc/CacheMvccTxFailoverTest.java | 3 +-
...gnitePdsBinaryMetadataOnClusterRestartTest.java | 12 +-
.../persistence/IgnitePdsCorruptedStoreTest.java | 3 +-
.../persistence/MaintenanceRegistrySimpleTest.java | 14 +-
...hangingBaselineDownCacheRemoveFailoverTest.java | 5 +-
...eChangingBaselineUpCacheRemoveFailoverTest.java | 5 +-
...gniteStableBaselineCacheRemoveFailoverTest.java | 5 +-
.../persistence/db/IgniteLogicalRecoveryTest.java | 7 +-
.../db/IgnitePdsDataRegionMetricsTest.java | 4 +-
.../db/IgnitePdsTransactionsHangTest.java | 4 +-
.../db/checkpoint/CheckpointFreeListTest.java | 6 +-
...CheckpointSimulationWithRealCpDisabledTest.java | 7 +-
.../db/file/IgnitePdsDiskErrorsRecoveringTest.java | 10 +-
.../wal/IgniteNodeStoppedDuringDisableWALTest.java | 4 +-
.../db/wal/reader/IgniteWalReaderTest.java | 6 +-
.../persistence/pagemem/NoOpPageStoreManager.java | 8 +-
.../cache/persistence/pagemem/NoOpWALManager.java | 5 +-
.../persistence/pagemem/PageMemoryImplTest.java | 8 +-
.../pagemem/PagesWriteThrottleSandboxTest.java | 3 +-
.../snapshot/AbstractSnapshotSelfTest.java | 31 +-
.../snapshot/IgniteClusterSnapshotCheckTest.java | 8 +-
.../IgniteClusterSnapshotRestoreBaseTest.java | 100 +++
.../IgniteClusterSnapshotRestoreSelfTest.java | 770 +++++++++++++++++
.../snapshot/IgniteClusterSnapshotSelfTest.java | 12 +-
.../snapshot/IgniteSnapshotManagerSelfTest.java | 7 +-
.../IgniteSnapshotWithMetastorageTest.java | 196 +++++
...inActiveNodeToActiveClusterWithPersistence.java | 6 +-
...InActiveNodeToActiveClusterWithPersistence.java | 6 +-
.../wal/SegmentedRingByteBufferTest.java | 4 +-
.../reader/StandaloneWalRecordsIteratorTest.java | 5 +-
...cheContinuousQueryFailoverAbstractSelfTest.java | 9 +-
.../CacheContinuousQueryRandomOperationsTest.java | 26 +-
...CacheContinuousWithTransformerFailoverTest.java | 13 +-
.../store/GridCacheWriteBehindStoreSelfTest.java | 5 +-
.../AbstractTransactionIntergrityTest.java | 19 +-
.../TxCrossCacheMapOnInvalidTopologyTest.java | 5 +-
.../cache/transactions/TxDeadlockCauseTest.java | 11 +-
.../TxDeadlockOnEntryToStringTest.java | 24 +-
...titionCounterStateOnePrimaryTwoBackupsTest.java | 3 +-
...titionCounterStateTwoPrimaryTwoBackupsTest.java | 5 +-
.../warmup/LoadAllWarmUpStrategySelfTest.java | 3 +-
.../database/IgniteDbMemoryLeakAbstractTest.java | 5 +-
.../failure/FailureProcessorLoggingTest.java | 4 +-
.../DurableBackgroundTasksProcessorSelfTest.java | 132 ++-
.../localtask/ObservingCheckpointListener.java | 16 +-
.../DistributedMetaStoragePersistentTest.java | 2 +-
.../persistence/DmsDataWriterWorkerTest.java | 43 +-
...ridServiceDeploymentCompoundFutureSelfTest.java | 3 +-
.../ServiceDeploymentProcessIdSelfTest.java | 6 +-
.../internal/sql/SqlParserCreateIndexSelfTest.java | 68 +-
.../internal/sql/SqlParserKillQuerySelfTest.java | 6 +-
.../util/IgniteUtilsWorkDirectoryTest.java | 3 +-
.../util/nio/impl/GridNioFilterChainSelfTest.java | 14 +-
.../loadtests/colocation/GridTestCacheStore.java | 3 +-
.../ignite/loadtests/job/GridJobLoadTest.java | 3 +-
.../lang/GridConcurrentLinkedHashMapBenchmark.java | 11 +-
.../marshaller/MarshallerContextTestImpl.java | 7 +-
.../ignite/messaging/GridMessagingSelfTest.java | 12 +-
...2PContinuousDeploymentClientDisconnectTest.java | 9 +-
.../apache/ignite/p2p/GridP2PUndeploySelfTest.java | 41 +-
.../session/GridSessionWaitAttributeSelfTest.java | 5 +-
.../tcp/GridTcpCommunicationSpiLogTest.java | 3 +-
.../IgniteTcpCommunicationConnectOnInitTest.java | 32 +-
.../tcp/TcpCommunicationStatisticsTest.java | 7 +-
.../local/GridLocalDeploymentSpiSelfTest.java | 54 +-
.../spi/discovery/tcp/IgniteClientConnectTest.java | 8 +-
.../tcp/TcpClientDiscoverySpiSelfTest.java | 18 +-
.../tcp/TcpDiscoveryCoordinatorFailureTest.java | 11 +-
.../tcp/TcpDiscoveryIpFinderFailureTest.java | 6 +-
.../tcp/TcpDiscoveryNodeJoinAndFailureTest.java | 8 +-
.../TcpDiscoveryPendingMessageDeliveryTest.java | 3 +-
.../tcp/TcpDiscoverySslParametersTest.java | 7 +-
.../vm/TcpDiscoveryVmIpFinderDnsResolveTest.java | 15 +-
.../GridInternalTasksLoadBalancingSelfTest.java | 3 +-
.../ignite/spi/metric/jmx/DummyMBeanServer.java | 7 +-
.../startup/servlet/GridServletLoaderTest.java | 3 +-
.../testframework/junits/GridAbstractTest.java | 6 +-
.../testframework/wal/record/RecordUtils.java | 3 +-
.../IgniteBasicWithPersistenceTestSuite.java | 4 +
.../testsuites/IgniteCacheMvccTestSuite2.java | 3 +-
.../testsuites/IgniteCacheMvccTestSuite6.java | 6 +-
.../ignite/testsuites/IgniteP2PSelfTestSuite.java | 6 +-
.../development/utils/IgniteWalConverter.java | 11 +-
.../utils/IgniteWalConverterArguments.java | 12 +-
.../development/utils/IgniteWalConverterTest.java | 15 +-
.../cache/persistence/file/IgniteNativeIoLib.java | 3 +-
...oteTransformerWithStaticInitializerFactory.java | 3 +-
...alCallable.java => ExternalEntryProcessor.java} | 29 +-
.../cache/hibernate/HibernateEntityRegion.java | 9 +-
.../hibernate/IgniteCachedDomainDataAccess.java | 15 +-
.../cache/hibernate/IgniteEntityDataAccess.java | 9 +-
.../cache/hibernate/IgniteNaturalIdDataAccess.java | 7 +-
.../HibernateL2CacheConfigurationSelfTest.java | 10 +-
.../HibernateL2CacheStrategySelfTest.java | 10 +-
.../processors/query/h2/IgniteH2Indexing.java | 8 +-
.../query/h2/database/H2PkHashIndex.java | 9 +-
.../processors/query/h2/opt/GridH2ProxyIndex.java | 9 +-
.../apache/ignite/client/FunctionalQueryTest.java | 3 +-
...finityKeyNameAndValueFieldNameConflictTest.java | 3 +-
.../cache/BinaryTypeMismatchLoggingTest.java | 3 +-
.../cache/CacheRegisterMetadataLocallyTest.java | 4 +-
...eckIndexesInlineSizeOnNodeJoinMultiJvmTest.java | 13 +-
.../cache/GridCacheDynamicLoadOnClientTest.java | 4 +-
.../IgniteCacheAbstractFieldsQuerySelfTest.java | 17 +-
...teCacheConfigurationPrimitiveTypesSelfTest.java | 3 +-
.../cache/IgniteDynamicSqlRestoreTest.java | 3 +-
.../QueryJoinWithDifferentNodeFiltersTest.java | 4 +-
.../processors/cache/index/BasicIndexTest.java | 4 +-
.../cache/index/H2RowExpireTimeIndexSelfTest.java | 6 +-
.../cache/index/QueryEntityValidationSelfTest.java | 6 +-
...acheMvccAbstractSqlCoordinatorFailoverTest.java | 4 +-
.../mvcc/CacheMvccBasicContinuousQueryTest.java | 9 +-
...eMvccPartitionedSqlCoordinatorFailoverTest.java | 10 +-
.../CacheMvccSqlConfigurationValidationTest.java | 7 +-
.../mvcc/CacheMvccSqlQueriesAbstractTest.java | 8 +-
.../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 5 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 3 +-
.../IgniteClusterSnapshotCheckWithIndexesTest.java | 2 +-
...niteClusterSnapshotRestoreWithIndexingTest.java | 211 +++++
.../RebuildIndexWithHistoricalRebalanceTest.java | 5 +-
...ngingBaselineCacheQueryNodeRestartSelfTest.java | 5 +-
...ableBaselineCacheQueryNodeRestartsSelfTest.java | 5 +-
.../query/IgniteSqlKeyValueFieldsTest.java | 3 +-
.../query/IgniteSqlSplitterSelfTest.java | 19 +-
.../query/KillQueryOnClientDisconnectTest.java | 11 +-
.../processors/query/SqlSystemViewsSelfTest.java | 40 +-
.../inlinecolumn/InlineIndexColumnTest.java | 92 +-
.../query/h2/sql/BaseH2CompareQueryTest.java | 15 +-
.../query/h2/sql/H2CompareBigQueryTest.java | 14 +-
.../DisappearedCacheCauseRetryMessageSelfTest.java | 5 +-
.../h2/twostep/RetryCauseMessageSelfTest.java | 9 +-
.../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +-
.../ml/sparkmodelparser/SparkModelParser.java | 5 +-
.../ml/sparkmodelparser/SparkModelParserTest.java | 5 +-
.../ignite/ml/clustering/kmeans/KMeansModel.java | 6 +-
.../ignite/ml/composition/ModelsComposition.java | 4 +-
.../ml/composition/bagging/BaggedTrainer.java | 4 +-
.../ml/dataset/impl/cache/CacheBasedDataset.java | 3 +-
.../impl/cache/CacheBasedDatasetBuilder.java | 14 +-
.../ml/dataset/impl/local/LocalDatasetBuilder.java | 5 +-
.../ignite/ml/knn/ann/ANNClassificationModel.java | 6 +-
.../ml/knn/ann/ANNClassificationTrainer.java | 9 +-
.../preprocessing/IllegalFeatureTypeException.java | 3 +-
.../preprocessing/IllegalLabelTypeException.java | 3 +-
.../ignite/ml/multiclass/MultiClassModel.java | 3 +-
.../ignite/ml/multiclass/OneVsRestTrainer.java | 3 +-
.../compound/CompoundNaiveBayesTrainer.java | 12 +-
.../apache/ignite/ml/nn/MultilayerPerceptron.java | 3 +-
.../updatecalculators/SimpleGDParameterUpdate.java | 3 +-
.../ml/preprocessing/encoding/EncoderTrainer.java | 4 +-
.../onehotencoder/OneHotEncoderPreprocessor.java | 6 +-
.../stringencoder/StringEncoderPreprocessor.java | 3 +-
.../preprocessing/imputing/ImputingStrategy.java | 5 +-
.../linear/LinearRegressionLSQRTrainer.java | 3 +-
.../linear/LinearRegressionSGDTrainer.java | 3 +-
.../logistic/LogisticRegressionSGDTrainer.java | 3 +-
.../ml/selection/cv/AbstractCrossValidation.java | 3 +-
...assificationPointwiseMetricStatsAggregator.java | 3 +-
.../ClassificationMetricsAggregator.java | 3 +-
.../RegressionMetricStatsAggregator.java | 3 +-
.../BinaryClassificationEvaluationContext.java | 3 +-
.../classification/BinaryClassificationMetric.java | 3 +-
.../ml/svm/SVMLinearClassificationTrainer.java | 3 +-
.../ml/trainers/AdaptableDatasetTrainer.java | 15 +-
.../apache/ignite/ml/trainers/DatasetTrainer.java | 9 +-
.../java/org/apache/ignite/ml/tree/NodeData.java | 8 +-
.../ignite/ml/util/genetic/GeneticAlgorithm.java | 3 +-
.../test/java/org/apache/ignite/ml/TestUtils.java | 6 +-
.../ignite/ml/clustering/KMeansTrainerTest.java | 3 +-
.../apache/ignite/ml/common/LocalModelsTest.java | 9 +-
.../ml/composition/boosting/GDBTrainerTest.java | 3 +-
.../primitive/SimpleLabeledDatasetTest.java | 3 +-
.../LearningEnvironmentBuilderTest.java | 16 +-
.../ml/environment/LearningEnvironmentTest.java | 11 +-
.../ml/environment/deploy/MLDeployingTest.java | 4 +-
.../ignite/ml/math/isolve/lsqr/LSQROnHeapTest.java | 9 +-
.../primitives/matrix/MatrixStorageFixtures.java | 3 +-
.../matrix/MatrixStorageImplementationTest.java | 9 +-
.../math/primitives/vector/AbstractVectorTest.java | 25 +-
.../ml/math/primitives/vector/VectorNormTest.java | 3 +-
.../ignite/ml/multiclass/OneVsRestTrainerTest.java | 3 +-
.../gaussian/GaussianNaiveBayesTrainerTest.java | 3 +-
.../test/java/org/apache/ignite/ml/nn/MLPTest.java | 6 +-
.../org/apache/ignite/ml/nn/MLPTrainerTest.java | 12 +-
.../ignite/ml/nn/performance/MnistMLPTestUtil.java | 7 +-
.../preprocessing/encoding/EncoderTrainerTest.java | 48 +-
.../preprocessing/imputing/ImputerTrainerTest.java | 30 +-
.../linear/LinearRegressionLSQRTrainerTest.java | 3 +-
.../logistic/LogisticRegressionSGDTrainerTest.java | 3 +-
.../ml/selection/cv/CrossValidationTest.java | 84 +-
.../cursor/CacheBasedLabelPairCursorTest.java | 3 +-
.../scoring/cursor/LocalLabelPairCursorTest.java | 3 +-
.../apache/ignite/ml/svm/SVMBinaryTrainerTest.java | 3 +-
.../RandomForestClassifierTrainerTest.java | 3 +-
.../RandomForestRegressionTrainerTest.java | 3 +-
.../ml/util/genetic/GeneticAlgorithmTest.java | 3 +-
.../http/jetty/GridJettyObjectMapper.java | 27 +-
.../protocols/http/jetty/GridJettyRestHandler.java | 6 +-
.../resource/GridResourceProcessorSelfTest.java | 3 +-
.../apache/ignite/spring/injection/spring-bean.xml | 3 +-
.../tools/ant/beautifier/GridJavadocAntTask.java | 3 +-
.../spi/deployment/uri/UriDeploymentSpi.java | 4 +-
.../UriDeploymentAbsentProcessorClassTest.java | 117 +++
.../testsuites/IgniteUriDeploymentTestSuite.java | 4 +-
.../servlet/ServletContextListenerStartup.java | 6 +-
.../ignite/startup/servlet/ServletStartup.java | 6 +-
.../ignite/yardstick/IgniteBenchmarkArguments.java | 6 +-
.../yardstick/cache/jdbc/RdbmsBenchmark.java | 4 +-
.../jdbc/NativeSqlJoinQueryRangeBenchmark.java | 6 +-
496 files changed, 6819 insertions(+), 2130 deletions(-)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotOperationRequest.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreProcess.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/metastorage/persistence/DmsWorkerStatus.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/RaceOnDeployClassesWithSameAliases.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/managers/deployment/GridDifferentLocalDeploymentSelfTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotRestoreBaseTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotRestoreSelfTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteSnapshotWithMetastorageTest.java
copy
modules/extdata/p2p/src/main/java/org/apache/ignite/tests/p2p/compute/{ExternalCallable.java
=> ExternalEntryProcessor.java} (72%)
create mode 100644
modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/IgniteClusterSnapshotRestoreWithIndexingTest.java
create mode 100644
modules/urideploy/src/test/java/org/apache/ignite/internal/UriDeploymentAbsentProcessorClassTest.java