Merge remote-tracking branch 'remotes/origin/master' into ignite-601
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/62aa742a Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/62aa742a Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/62aa742a Branch: refs/heads/ignite-601 Commit: 62aa742a868f64584f95a19c167a60bd67e57840 Parents: 8a7d3b4 601d956 Author: sboikov <sboi...@apache.org> Authored: Tue Dec 25 16:59:22 2018 +0300 Committer: sboikov <sboi...@apache.org> Committed: Tue Dec 25 16:59:22 2018 +0300 ---------------------------------------------------------------------- .../misc/schedule/ComputeScheduleExample.java | 4 +- .../ml/selection/cv/CrossValidationExample.java | 23 +- .../Step_8_CV_with_Param_Grid_and_metrics.java | 192 ++++++ ...ComputeScheduleExampleMultiNodeSelfTest.java | 31 + .../ComputeScheduleExampleSelfTest.java | 33 ++ .../HibernateL2CacheExampleSelfTest.java | 8 +- .../examples/SpatialQueryExampleSelfTest.java | 2 + .../IgniteLgplExamplesSelfTestSuite.java | 23 +- .../examples/CheckpointExamplesSelfTest.java | 2 + .../examples/ClusterGroupExampleSelfTest.java | 2 + .../ContinuationExamplesMultiNodeSelfTest.java | 5 +- .../examples/ContinuationExamplesSelfTest.java | 2 + ...ntinuousMapperExamplesMultiNodeSelfTest.java | 5 +- .../ContinuousMapperExamplesSelfTest.java | 2 + .../DeploymentExamplesMultiNodeSelfTest.java | 7 +- .../examples/DeploymentExamplesSelfTest.java | 2 + .../ignite/examples/IgfsExamplesSelfTest.java | 2 + .../examples/LifecycleExamplesSelfTest.java | 2 + .../MemcacheRestExamplesMultiNodeSelfTest.java | 7 +- .../examples/MemcacheRestExamplesSelfTest.java | 2 + .../MonteCarloExamplesMultiNodeSelfTest.java | 5 +- .../examples/MonteCarloExamplesSelfTest.java | 2 + .../examples/SpringBeanExamplesSelfTest.java | 2 + .../examples/TaskExamplesMultiNodeSelfTest.java | 5 +- .../ignite/examples/TaskExamplesSelfTest.java | 2 + .../testsuites/IgniteExamplesMLTestSuite.java | 40 +- .../testsuites/IgniteExamplesSelfTestSuite.java | 10 +- .../IgniteExamplesSparkSelfTestSuite.java | 15 +- .../apache/ignite/gridify/AbstractAopTest.java | 8 - .../testsuites/IgniteAopSelfTestSuite.java | 5 +- .../ignite/testsuites/IgniteElbTestSuite.java | 5 +- .../ignite/testsuites/IgniteS3TestSuite.java | 5 +- .../camel/IgniteCamelStreamerTestSuite.java | 5 +- .../ignite/tests/CassandraConfigTest.java | 12 +- .../ClientAbstractMultiThreadedSelfTest.java | 12 - .../client/ClientDefaultCacheSelfTest.java | 12 - .../client/impl/ClientCacheFlagsCodecTest.java | 9 +- .../ClientAbstractMultiNodeSelfTest.java | 12 - .../integration/ClientAbstractSelfTest.java | 12 - .../integration/ClientPreferDirectSelfTest.java | 12 - .../client/router/ClientFailedInitSelfTest.java | 12 - .../client/router/RouterFactorySelfTest.java | 7 +- .../client/router/TcpSslRouterSelfTest.java | 6 +- .../client/suite/IgniteClientTestSuite.java | 7 +- .../ignite/internal/jdbc2/JdbcBlobTest.java | 10 +- .../jdbc2/JdbcComplexQuerySelfTest.java | 12 - .../internal/jdbc2/JdbcConnectionSelfTest.java | 12 - .../jdbc2/JdbcDistributedJoinsQueryTest.java | 12 - .../internal/jdbc2/JdbcEmptyCacheSelfTest.java | 12 - .../internal/jdbc2/JdbcLocalCachesSelfTest.java | 12 - .../internal/jdbc2/JdbcMetadataSelfTest.java | 12 - .../internal/jdbc2/JdbcNoDefaultCacheTest.java | 12 - .../jdbc2/JdbcPreparedStatementSelfTest.java | 12 - .../internal/jdbc2/JdbcResultSetSelfTest.java | 12 - .../internal/jdbc2/JdbcStatementSelfTest.java | 12 - .../rest/AbstractRestProcessorSelfTest.java | 12 - .../rest/ChangeStateCommandHandlerTest.java | 12 - .../rest/RestBinaryProtocolSelfTest.java | 12 - .../rest/RestMemcacheProtocolSelfTest.java | 12 - .../rest/RestProcessorStartSelfTest.java | 7 +- .../rest/TaskCommandHandlerSelfTest.java | 12 - .../tcp/redis/RedisCommonAbstractTest.java | 12 - .../jdbc/AbstractJdbcPojoQuerySelfTest.java | 11 - .../ignite/jdbc/JdbcComplexQuerySelfTest.java | 12 - .../ignite/jdbc/JdbcConnectionSelfTest.java | 12 - .../ignite/jdbc/JdbcEmptyCacheSelfTest.java | 12 - .../ignite/jdbc/JdbcLocalCachesSelfTest.java | 12 - .../ignite/jdbc/JdbcMetadataSelfTest.java | 12 - .../ignite/jdbc/JdbcNoDefaultCacheTest.java | 12 - .../jdbc/JdbcPreparedStatementSelfTest.java | 12 - .../ignite/jdbc/JdbcResultSetSelfTest.java | 12 - .../ignite/jdbc/JdbcStatementSelfTest.java | 12 - .../suite/IgniteJdbcDriverMvccTestSuite.java | 5 +- .../jdbc/suite/IgniteJdbcDriverTestSuite.java | 8 +- .../JdbcThinAbstractDmlStatementSelfTest.java | 12 - .../JdbcThinAuthenticateConnectionSelfTest.java | 12 - .../thin/JdbcThinAutoCloseServerCursorTest.java | 12 - .../thin/JdbcThinComplexDmlDdlSelfTest.java | 12 - .../jdbc/thin/JdbcThinComplexQuerySelfTest.java | 12 - ...JdbcThinConnectionMultipleAddressesTest.java | 12 - .../JdbcThinConnectionMvccEnabledSelfTest.java | 12 - .../jdbc/thin/JdbcThinConnectionSSLTest.java | 12 - .../jdbc/thin/JdbcThinConnectionSelfTest.java | 12 - .../jdbc/thin/JdbcThinDataSourceSelfTest.java | 12 - .../jdbc/thin/JdbcThinEmptyCacheSelfTest.java | 12 - .../jdbc/thin/JdbcThinMetadataSelfTest.java | 20 - .../JdbcThinMissingLongArrayResultsTest.java | 12 - .../jdbc/thin/JdbcThinNoDefaultSchemaTest.java | 12 - .../thin/JdbcThinPreparedStatementSelfTest.java | 12 - .../jdbc/thin/JdbcThinResultSetSelfTest.java | 12 - .../jdbc/thin/JdbcThinSchemaCaseTest.java | 12 - .../thin/JdbcThinSelectAfterAlterTable.java | 12 - .../jdbc/thin/JdbcThinStatementSelfTest.java | 12 - .../thin/JdbcThinStreamingAbstractSelfTest.java | 5 +- ...ThinTransactionsAbstractComplexSelfTest.java | 2 + .../jdbc/thin/JdbcThinTransactionsSelfTest.java | 12 - ...ThinTransactionsWithMvccEnabledSelfTest.java | 12 - .../ignite/testsuites/IgniteCloudTestSuite.java | 5 +- .../compress/FileSystemUtilsTest.java | 8 +- .../apache/ignite/IgniteSystemProperties.java | 7 + .../ignite/failure/AbstractFailureHandler.java | 5 +- .../org/apache/ignite/failure/FailureType.java | 5 +- .../ignite/internal/TransactionsMXBeanImpl.java | 8 +- .../ignite/internal/commandline/Command.java | 5 + .../internal/commandline/CommandHandler.java | 241 +++++--- .../commandline/cache/CacheCommand.java | 5 + .../discovery/GridDiscoveryManager.java | 18 +- .../pagemem/wal/IgniteWriteAheadLogManager.java | 10 + .../affinity/GridAffinityProcessor.java | 195 ++++--- .../processors/bulkload/BulkLoadProcessor.java | 25 +- .../processors/cache/GridCacheContext.java | 12 + .../processors/cache/GridCacheMapEntry.java | 168 +++--- .../processors/cache/GridCacheProcessor.java | 14 + .../dht/preloader/GridDhtPartitionDemander.java | 27 +- .../cache/persistence/DataStructure.java | 2 +- .../GridCacheDatabaseSharedManager.java | 42 +- .../persistence/pagemem/PageMemoryImpl.java | 14 + .../wal/FileWriteAheadLogManager.java | 215 ++++--- .../wal/aware/SegmentArchivedStorage.java | 7 + .../persistence/wal/aware/SegmentAware.java | 11 + .../wal/aware/SegmentCompressStorage.java | 7 + .../wal/aware/SegmentCurrentStateStorage.java | 9 + .../wal/filehandle/FileHandleManager.java | 10 - .../wal/filehandle/FileHandleManagerImpl.java | 95 +-- .../filehandle/FsyncFileHandleManagerImpl.java | 10 - .../wal/serializer/RecordDataV1Serializer.java | 2 +- .../wal/serializer/RecordDataV2Serializer.java | 4 +- .../verify/VerifyBackupPartitionsDumpTask.java | 5 +- .../processors/query/GridQueryIndexing.java | 9 +- .../processors/query/GridQueryProcessor.java | 6 +- .../internal/processors/query/QueryUtils.java | 9 +- .../processors/query/RunningQueryManager.java | 130 +++++ .../processors/task/GridTaskWorker.java | 14 +- .../util/Jsr310Java8DateTimeApiUtils.java | 80 --- .../internal/util/OffheapReadWriteLock.java | 2 +- .../node/VisorCacheRebalanceCollectorTask.java | 2 +- .../visor/node/VisorNodeDataCollectorJob.java | 4 +- .../internal/visor/tx/VisorTxSortOrder.java | 17 - .../ignite/spi/discovery/tcp/ServerImpl.java | 5 + .../GridCacheAffinityBackupsSelfTest.java | 8 - .../ignite/GridSuppressedExceptionSelfTest.java | 12 +- .../cache/IgniteWarmupClosureSelfTest.java | 12 - .../ignite/cache/ResetLostPartitionTest.java | 8 - .../affinity/AffinityClientNodeSelfTest.java | 8 - ...ityFunctionBackupFilterAbstractSelfTest.java | 10 - ...unctionExcludeNeighborsAbstractSelfTest.java | 7 +- .../affinity/AffinityHistoryCleanupTest.java | 8 - .../local/LocalAffinityFunctionTest.java | 8 - ...RWThroughDisabledTransactionalCacheTest.java | 2 - ...cheStoreSessionListenerAbstractSelfTest.java | 20 - ...heStoreSessionListenerLifecycleSelfTest.java | 12 - ...reSessionListenerWriteBehindEnabledTest.java | 2 - .../store/StoreResourceInjectionSelfTest.java | 12 - .../CacheJdbcPojoStoreAbstractSelfTest.java | 12 - ...eJdbcStoreAbstractMultithreadedSelfTest.java | 12 - ...CacheJdbcBlobStoreMultithreadedSelfTest.java | 12 - .../failure/SystemWorkersBlockingTest.java | 17 +- .../igfs/IgfsFragmentizerAbstractSelfTest.java | 12 - .../apache/ignite/internal/ClassSetTest.java | 9 +- .../ClusterBaselineNodesMetricsSelfTest.java | 8 - .../internal/ClusterGroupAbstractTest.java | 7 +- .../internal/ClusterNodeMetricsSelfTest.java | 12 - .../internal/ClusterNodeMetricsUpdateTest.java | 8 - .../ComputeJobCancelWithServiceSelfTest.java | 16 - .../ignite/internal/GridAffinityMappedTest.java | 12 - .../internal/GridAffinityP2PSelfTest.java | 12 - .../ignite/internal/GridAffinitySelfTest.java | 12 - ...chePartitionExchangeManagerHistSizeTest.java | 8 - .../internal/GridDiscoveryEventSelfTest.java | 13 - .../ignite/internal/GridDiscoverySelfTest.java | 12 - ...ridFailFastNodeFailureDetectionSelfTest.java | 10 +- .../GridJobMasterLeaveAwareSelfTest.java | 11 - .../internal/GridJobServicesAddNodeTest.java | 12 - .../internal/GridMultipleJobsSelfTest.java | 12 - .../GridProjectionForCachesSelfTest.java | 20 - ...ectionLocalJobMultipleArgumentsSelfTest.java | 12 - .../internal/GridReleaseTypeSelfTest.java | 7 +- .../GridTaskFailoverAffinityRunTest.java | 7 - .../IgniteClientReconnectAbstractTest.java | 7 +- .../IgniteComputeEmptyClusterGroupTest.java | 12 - ...onnectionConcurrentReserveAndRemoveTest.java | 12 - .../IgniteReflectionFactorySelfTest.java | 8 +- .../IgniteSlowClientDetectionSelfTest.java | 6 - ...UpdateNotifierPerClusterSettingSelfTest.java | 8 - .../ignite/internal/TaskNodeRestartTest.java | 8 - .../TransactionMetricsMxBeanImplTest.java | 8 - .../internal/TransactionsMXBeanImplTest.java | 8 - .../binary/BinaryObjectExceptionSelfTest.java | 7 - .../binary/BinaryObjectToStringSelfTest.java | 7 - .../BinaryObjectTypeCompatibilityTest.java | 16 - .../binary/GridBinaryAffinityKeySelfTest.java | 8 - .../commandline/CommandHandlerParsingTest.java | 34 +- ...ByteBufferStreamImplV2ByteOrderSelfTest.java | 16 +- ...GridManagerLocalMessageListenerSelfTest.java | 12 - ...dManagerMxBeanIllegalArgumentHandleTest.java | 15 +- .../managers/IgniteDiagnosticMessagesTest.java | 15 +- .../GridCheckpointManagerAbstractSelfTest.java | 12 - .../checkpoint/GridCheckpointTaskSelfTest.java | 19 - .../GridCommunicationSendMessageSelfTest.java | 12 - .../IgniteCommunicationBalanceTest.java | 8 - .../communication/IgniteIoTestMessagesTest.java | 8 - .../IgniteVariousConnectionNumberTest.java | 8 - ...mentRequestOfUnknownClassProcessingTest.java | 12 - .../GridDeploymentMessageCountSelfTest.java | 12 - .../GridDiscoveryManagerAliveCacheSelfTest.java | 9 +- .../GridDiscoveryManagerAttributesSelfTest.java | 11 - .../IgniteTopologyPrintFormatSelfTest.java | 12 +- .../OptimizedMarshallerEnumSelfTest.java | 8 +- .../OptimizedMarshallerNodeFailoverTest.java | 12 - .../GridCacheTxLoadFromStoreOnLockSelfTest.java | 12 - .../GridAffinityProcessorAbstractSelfTest.java | 12 +- .../GridAffinityProcessorMemoryLeakTest.java | 13 +- .../Authentication1kUsersNodeRestartTest.java | 12 - .../AuthenticationConfigurationClusterTest.java | 12 - .../AuthenticationOnNotActiveClusterTest.java | 12 - .../AuthenticationProcessorNPEOnStartTest.java | 12 - .../AuthenticationProcessorNodeRestartTest.java | 12 - .../AuthenticationProcessorSelfTest.java | 12 - .../cache/CacheAffinityCallSelfTest.java | 83 ++- .../CacheAtomicSingleMessageCountSelfTest.java | 12 +- .../cache/CacheClientStoreSelfTest.java | 12 - .../processors/cache/CacheComparatorTest.java | 8 +- .../cache/CacheConcurrentReadThroughTest.java | 8 - .../cache/CacheConnectionLeakStoreTxTest.java | 11 - .../cache/CacheDeferredDeleteQueueTest.java | 4 +- .../CacheDeferredDeleteSanitySelfTest.java | 7 +- .../cache/CacheEnumOperationsAbstractTest.java | 12 +- ...CacheExchangeMessageDuplicatedStateTest.java | 8 - .../cache/CacheFutureExceptionSelfTest.java | 12 - ...tEntryPessimisticRepeatableReadSelfTest.java | 7 +- .../cache/CacheGroupsMetricsRebalanceTest.java | 83 ++- ...torPartitionCounterRandomOperationsTest.java | 8 - .../cache/CacheMetricsManageTest.java | 8 - .../cache/CacheNearReaderUpdateTest.java | 8 - ...cheOptimisticTransactionsWithFilterTest.java | 8 - .../CachePutEventListenerErrorSelfTest.java | 12 - .../processors/cache/CachePutIfAbsentTest.java | 16 - .../cache/CacheReadThroughRestartSelfTest.java | 12 - .../cache/CacheRemoveAllSelfTest.java | 2 - .../CacheSerializableTransactionsTest.java | 32 +- .../cache/CacheStopAndDestroySelfTest.java | 6 - .../CacheStoreUsageMultinodeAbstractTest.java | 8 - .../processors/cache/CacheTxFastFinishTest.java | 8 - .../CacheTxNotAllowReadFromBackupTest.java | 7 - .../processors/cache/CrossCacheLockTest.java | 8 - .../cache/CrossCacheTxRandomOperationsTest.java | 8 - .../DataStorageConfigurationValidationTest.java | 8 +- ...idAbstractCacheInterceptorRebalanceTest.java | 8 - ...ridCacheAbstractByteArrayValuesSelfTest.java | 20 - .../cache/GridCacheAbstractFullApiSelfTest.java | 5 - .../GridCacheAbstractLocalStoreSelfTest.java | 12 - .../GridCacheAbstractRemoveFailureTest.java | 7 +- ...acheAbstractUsersAffinityMapperSelfTest.java | 12 - .../cache/GridCacheAffinityRoutingSelfTest.java | 12 - ...eAtomicEntryProcessorDeploymentSelfTest.java | 12 - .../GridCacheAtomicMessageCountSelfTest.java | 12 +- .../cache/GridCacheBasicStoreAbstractTest.java | 14 - .../cache/GridCacheClearAllSelfTest.java | 12 - .../cache/GridCacheClearLocallySelfTest.java | 12 - .../cache/GridCacheClearSelfTest.java | 20 - ...GridCacheConcurrentGetCacheOnClientTest.java | 16 - .../cache/GridCacheConcurrentMapSelfTest.java | 12 - .../GridCacheConcurrentTxMultiNodeLoadTest.java | 12 - .../GridCacheConditionalDeploymentSelfTest.java | 12 - ...idCacheConfigurationConsistencySelfTest.java | 12 - ...ridCacheConfigurationValidationSelfTest.java | 12 - .../GridCacheDaemonNodeAbstractSelfTest.java | 12 - .../cache/GridCacheDeploymentSelfTest.java | 12 - .../cache/GridCacheEntryMemorySizeSelfTest.java | 12 - .../cache/GridCacheEntryVersionSelfTest.java | 12 - .../GridCacheEvictionEventAbstractTest.java | 14 - ...idCacheGetAndTransformStoreAbstractTest.java | 14 - .../cache/GridCacheIncrementTransformTest.java | 12 - .../GridCacheInterceptorAbstractSelfTest.java | 12 - .../GridCacheInterceptorLocalSelfTest.java | 2 - ...dCacheInterceptorLocalWithStoreSelfTest.java | 2 - .../cache/GridCacheIteratorPerformanceTest.java | 12 - .../cache/GridCacheKeyCheckSelfTest.java | 12 - .../processors/cache/GridCacheLeakTest.java | 12 - .../GridCacheMarshallerTxAbstractTest.java | 20 - .../GridCacheMarshallingNodeJoinSelfTest.java | 14 - ...GridCacheMixedPartitionExchangeSelfTest.java | 7 +- .../cache/GridCacheMultiUpdateLockSelfTest.java | 12 - ...ridCacheMultinodeUpdateAbstractSelfTest.java | 4 + ...CacheMultinodeUpdateNearEnabledSelfTest.java | 2 - .../cache/GridCacheMvccManagerSelfTest.java | 12 - .../cache/GridCacheMvccPartitionedSelfTest.java | 12 - .../processors/cache/GridCacheMvccSelfTest.java | 12 - .../cache/GridCacheNestedTxAbstractTest.java | 20 - .../cache/GridCacheObjectToStringSelfTest.java | 10 - .../GridCacheOnCopyFlagAbstractSelfTest.java | 12 - .../GridCacheOrderedPreloadingSelfTest.java | 12 - .../cache/GridCacheP2PUndeploySelfTest.java | 12 - .../cache/GridCachePartitionedGetSelfTest.java | 19 - ...hePartitionedProjectionAffinitySelfTest.java | 12 - .../GridCachePreloadingEvictionsSelfTest.java | 12 - .../cache/GridCachePutAllFailoverSelfTest.java | 8 +- .../GridCacheReferenceCleanupSelfTest.java | 9 - ...ridCacheReplicatedSynchronousCommitTest.java | 12 - .../cache/GridCacheSlowTxWarnTest.java | 12 - .../processors/cache/GridCacheStopSelfTest.java | 12 - ...ridCacheStoreManagerDeserializationTest.java | 14 - .../cache/GridCacheStoreValueBytesSelfTest.java | 12 - .../GridCacheTtlManagerEvictionSelfTest.java | 12 - .../GridCacheTtlManagerNotificationTest.java | 12 - .../cache/GridCacheTtlManagerSelfTest.java | 12 - .../GridCacheVariableTopologySelfTest.java | 14 - .../cache/GridCacheVersionMultinodeTest.java | 7 +- .../GridCacheVersionTopologyChangeTest.java | 16 - ...StorageConfigurationConsistencySelfTest.java | 11 - ...ProjectionForCachesOnDaemonNodeSelfTest.java | 20 - .../IgniteCacheAbstractStopBusySelfTest.java | 7 +- .../cache/IgniteCacheAbstractTest.java | 9 +- ...IgniteCacheBinaryEntryProcessorSelfTest.java | 8 - .../IgniteCacheBinaryObjectsScanSelfTest.java | 11 - ...teCacheConfigurationDefaultTemplateTest.java | 8 - .../IgniteCacheConfigurationTemplateTest.java | 7 +- .../cache/IgniteCacheCreateRestartSelfTest.java | 8 - ...niteCacheEntryListenerExpiredEventsTest.java | 16 - .../IgniteCacheEntryProcessorCallTest.java | 8 - .../IgniteCacheEntryProcessorNodeJoinTest.java | 12 - ...niteCacheExpireAndUpdateConsistencyTest.java | 8 - ...IgniteCacheGetCustomCollectionsSelfTest.java | 12 - .../processors/cache/IgniteCacheGroupsTest.java | 11 +- .../cache/IgniteCacheIncrementTxTest.java | 8 - .../IgniteCacheInterceptorSelfTestSuite.java | 7 +- ...gniteCacheInvokeReadThroughAbstractTest.java | 8 - ...iteCacheInvokeReadThroughSingleNodeTest.java | 2 - .../cache/IgniteCacheInvokeReadThroughTest.java | 2 - ...gniteCacheLoadRebalanceEvictionSelfTest.java | 12 - .../IgniteCacheMvccTxNearEnabledInvokeTest.java | 11 +- .../cache/IgniteCacheNearLockValueSelfTest.java | 7 +- .../cache/IgniteCacheNoSyncForGetTest.java | 8 - .../IgniteCachePartitionMapUpdateTest.java | 8 - .../cache/IgniteCachePutAllRestartTest.java | 8 - .../IgniteCachePutStackOverflowSelfTest.java | 20 - .../IgniteCacheReadThroughEvictionSelfTest.java | 2 - ...acheReadThroughEvictionsVariationsSuite.java | 5 +- .../IgniteCacheReadThroughStoreCallTest.java | 10 - ...iteCacheScanPredicateDeploymentSelfTest.java | 12 - .../cache/IgniteCacheSerializationSelfTest.java | 8 - .../processors/cache/IgniteCacheStartTest.java | 8 - .../cache/IgniteCacheStoreCollectionTest.java | 8 - .../IgniteCacheTxCopyOnReadDisabledTest.java | 2 - .../cache/IgniteCacheTxLocalPeekModesTest.java | 2 - .../cache/IgniteCacheTxLocalStoreValueTest.java | 2 - .../IgniteCacheTxNearEnabledStoreValueTest.java | 2 - .../cache/IgniteCacheTxNearPeekModesTest.java | 2 - .../cache/IgniteCacheTxPreloadNoWriteTest.java | 12 - .../cache/IgniteCacheTxStoreValueTest.java | 2 - .../IgniteClientAffinityAssignmentSelfTest.java | 8 - ...IgniteClientCacheInitializationFailTest.java | 11 +- .../IgniteClientCacheStartFailoverTest.java | 8 - .../IgniteClusterActivateDeactivateTest.java | 7 +- ...erActivateDeactivateTestWithPersistence.java | 16 + ...tivateTestWithPersistenceAndMemoryReuse.java | 27 + .../IgniteDaemonNodeMarshallerCacheTest.java | 8 - .../cache/IgniteDynamicCacheAndNodeStop.java | 15 - .../cache/IgniteDynamicCacheFilterTest.java | 8 - .../cache/IgniteDynamicCacheMultinodeTest.java | 8 - ...ynamicCacheStartCoordinatorFailoverTest.java | 11 - ...eDynamicCacheStartNoExchangeTimeoutTest.java | 8 - .../cache/IgniteDynamicCacheStartSelfTest.java | 7 - ...niteDynamicCacheStartStopConcurrentTest.java | 16 - ...niteDynamicCacheWithConfigStartSelfTest.java | 12 - .../IgniteDynamicClientCacheStartSelfTest.java | 8 - ...IgniteGetNonPlainKeyReadThroughSelfTest.java | 7 - .../cache/IgniteInternalCacheTypesTest.java | 8 - ...eMarshallerCacheConcurrentReadWriteTest.java | 8 - .../cache/IgniteNearClientCacheCloseTest.java | 8 - .../cache/IgniteOnePhaseCommitInvokeTest.java | 8 - .../IgniteOnePhaseCommitNearReadersTest.java | 8 - .../cache/IgnitePdsDataRegionMetricsTxTest.java | 1 + .../IgniteStartCacheInTransactionSelfTest.java | 8 - .../cache/IgniteSystemCacheOnClientTest.java | 8 - .../processors/cache/IgniteTxAbstractTest.java | 20 - .../IgniteTxConcurrentGetAbstractTest.java | 20 - .../cache/IgniteTxConfigCacheSelfTest.java | 8 - .../cache/IgniteTxMultiNodeAbstractTest.java | 20 - .../cache/IgniteTxReentryAbstractSelfTest.java | 11 - .../MarshallerCacheJobRunNodeRestartTest.java | 8 - ...AffinityCoordinatorDynamicStartStopTest.java | 9 - .../SetTxTimeoutOnPartitionMapExchangeTest.java | 16 - .../WalModeChangeCommonAbstractSelfTest.java | 7 - .../binary/BinaryMetadataUpdatesFlowTest.java | 7 +- .../CacheKeepBinaryWithInterceptorTest.java | 8 - ...naryObjectMetadataExchangeMultinodeTest.java | 7 +- ...acheBinaryObjectUserClassloaderSelfTest.java | 12 - ...aryObjectsAbstractMultiThreadedSelfTest.java | 8 - .../GridCacheBinaryObjectsAbstractSelfTest.java | 12 - .../GridCacheBinaryStoreAbstractSelfTest.java | 12 - ...ntNodeBinaryObjectMetadataMultinodeTest.java | 7 +- .../GridDataStreamerImplSelfTest.java | 11 - .../GridCacheQueueClientDisconnectTest.java | 13 +- ...ridCacheQueueJoinedNodeSelfAbstractTest.java | 5 - .../IgniteAtomicsAbstractTest.java | 12 - .../IgniteClientDataStructuresAbstractTest.java | 7 - .../IgniteCollectionAbstractTest.java | 12 - .../IgniteDataStructureWithJobTest.java | 16 - .../IgniteSequenceInternalCleanupTest.java | 12 - .../SemaphoreFailoverNoWaitingAcquirerTest.java | 12 - ...SemaphoreFailoverSafeReleasePermitsTest.java | 12 - ...achePartitionedAtomicSequenceTxSelfTest.java | 12 - ...idCachePartitionedNodeRestartTxSelfTest.java | 12 - .../distributed/CacheAffinityEarlyTest.java | 11 - .../distributed/CacheAsyncOperationsTest.java | 8 - .../distributed/CacheBaselineTopologyTest.java | 10 - .../CacheClientsConcurrentStartTest.java | 7 - .../CacheDiscoveryDataConcurrentJoinTest.java | 7 +- .../distributed/CacheExchangeMergeTest.java | 8 - .../CacheGetFutureHangsSelfTest.java | 8 - .../CacheGetInsideLockChangingTopologyTest.java | 7 - .../distributed/CacheGroupsPreloadTest.java | 15 +- ...ffinityAssignmentNodeJoinValidationTest.java | 8 - .../CacheLateAffinityAssignmentTest.java | 10 +- .../CacheLockReleaseNodeLeaveTest.java | 10 +- .../CacheOperationsInterruptTest.java | 8 - .../distributed/CacheParallelStartTest.java | 11 - .../distributed/CachePartitionStateTest.java | 8 - .../CacheRentingStateRepairTest.java | 11 - ...CacheResultIsNotNullOnPartitionLossTest.java | 7 - .../cache/distributed/CacheStartOnJoinTest.java | 7 +- .../CacheTryLockMultithreadedTest.java | 8 - .../GridCacheAbstractJobExecutionTest.java | 20 - .../GridCacheAbstractNodeRestartSelfTest.java | 46 +- .../GridCacheAbstractPrimarySyncSelfTest.java | 12 - .../GridCacheBasicOpAbstractTest.java | 20 - .../distributed/GridCacheLockAbstractTest.java | 14 - .../GridCacheMultiNodeAbstractTest.java | 20 - .../GridCacheMultiNodeLockAbstractTest.java | 14 - ...dCacheMultithreadedFailoverAbstractTest.java | 11 - .../GridCacheNodeFailureAbstractTest.java | 14 - ...ridCachePartitionNotLoadedEventSelfTest.java | 10 - ...chePartitionedReloadAllAbstractSelfTest.java | 12 - .../GridCachePreloadEventsAbstractSelfTest.java | 10 - .../GridCachePreloadLifecycleAbstractTest.java | 12 - ...GridCachePreloadRestartAbstractSelfTest.java | 11 - .../GridCacheTransformEventSelfTest.java | 11 - ...yMetadataUpdateChangingTopologySelfTest.java | 12 - ...niteBinaryMetadataUpdateNodeRestartTest.java | 8 - .../distributed/IgniteCache150ClientsTest.java | 6 - ...heClientMultiNodeUpdateTopologyLockTest.java | 8 - ...niteCacheClientNodeChangingTopologyTest.java | 7 +- .../IgniteCacheClientNodeConcurrentStart.java | 8 - ...teCacheClientNodePartitionsExchangeTest.java | 7 +- .../IgniteCacheClientReconnectTest.java | 7 - .../IgniteCacheConnectionRecoveryTest.java | 8 - .../IgniteCacheCreatePutMultiNodeSelfTest.java | 11 - .../distributed/IgniteCacheCreatePutTest.java | 11 - .../distributed/IgniteCacheGetRestartTest.java | 8 - ...eCacheGroupsPartitionLossPolicySelfTest.java | 8 - .../distributed/IgniteCacheManyClientsTest.java | 6 - ...eCacheMessageRecoveryIdleConnectionTest.java | 8 - .../IgniteCacheMessageWriteTimeoutTest.java | 8 - .../IgniteCacheNearRestartRollbackSelfTest.java | 12 +- .../IgniteCachePartitionLossPolicySelfTest.java | 8 - .../distributed/IgniteCachePrimarySyncTest.java | 8 - .../IgniteCacheReadFromBackupTest.java | 8 - .../IgniteCacheServerNodeConcurrentStart.java | 6 - .../IgniteCacheSingleGetMessageTest.java | 8 - .../IgniteCacheSizeFailoverTest.java | 8 - .../IgniteCacheThreadLocalTxTest.java | 8 - .../IgniteMvccTxTimeoutAbstractTest.java | 12 - .../IgniteNoClassOnServerAbstractTest.java | 4 +- .../IgniteRejectConnectOnNodeStopTest.java | 7 +- .../IgniteTxCachePrimarySyncTest.java | 8 - ...teSynchronizationModesMultithreadedTest.java | 8 - .../IgniteTxConcurrentRemoveObjectsTest.java | 16 - ...iteTxConsistencyRestartAbstractSelfTest.java | 12 - .../IgniteTxRemoveTimeoutObjectsTest.java | 2 - .../IgniteTxTimeoutAbstractTest.java | 12 - .../dht/CacheGetReadFromBackupFailoverTest.java | 7 - ...heAbstractTransformWriteThroughSelfTest.java | 12 - .../dht/GridCacheColocatedDebugTest.java | 12 - ...eColocatedOptimisticTransactionSelfTest.java | 11 - ...dCacheColocatedTxSingleThreadedSelfTest.java | 12 - .../dht/GridCacheDhtEntrySelfTest.java | 12 - ...GridCacheDhtEvictionNearReadersSelfTest.java | 12 - .../GridCacheDhtEvictionsDisabledSelfTest.java | 12 - .../dht/GridCacheDhtMappingSelfTest.java | 11 - .../dht/GridCacheDhtPreloadBigDataSelfTest.java | 11 - .../dht/GridCacheDhtPreloadDelayedSelfTest.java | 11 - .../GridCacheDhtPreloadDisabledSelfTest.java | 11 - .../GridCacheDhtPreloadMessageCountTest.java | 11 - ...ridCacheDhtPreloadMultiThreadedSelfTest.java | 8 - .../dht/GridCacheDhtPreloadPerformanceTest.java | 12 - .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 11 - .../dht/GridCacheDhtPreloadSelfTest.java | 11 - .../GridCacheDhtPreloadStartStopSelfTest.java | 11 - .../dht/GridCacheDhtPreloadUnloadSelfTest.java | 11 - ...dCachePartitionedTopologyChangeSelfTest.java | 13 - ...ridCachePartitionedUnloadEventsSelfTest.java | 10 - .../GridCachePartitionsStateValidationTest.java | 4 + .../dht/GridCacheTxNodeFailureSelfTest.java | 8 - ...gniteAtomicLongChangingTopologySelfTest.java | 11 +- .../IgniteCacheClearDuringRebalanceTest.java | 12 - .../IgniteCacheCommitDelayTxRecoveryTest.java | 8 - .../dht/IgniteCacheConcurrentPutGetRemove.java | 16 - .../IgniteCacheCrossCacheTxFailoverTest.java | 11 +- .../dht/IgniteCacheLockFailoverSelfTest.java | 2 - .../dht/IgniteCacheMultiTxLockSelfTest.java | 14 - .../IgniteCachePutRetryAbstractSelfTest.java | 8 - .../dht/IgniteCacheTxRecoveryRollbackTest.java | 8 - .../dht/IgniteCrossCacheTxAbstractSelfTest.java | 16 - .../AtomicPutAllChangingTopologyTest.java | 16 - ...eAtomicInvalidPartitionHandlingSelfTest.java | 7 +- .../atomic/IgniteCacheAtomicProtocolTest.java | 7 - ...tNearPartitionedByteArrayValuesSelfTest.java | 12 +- .../near/GridCacheGetStoreErrorSelfTest.java | 12 - .../near/GridCacheMvccNearEvictionSelfTest.java | 10 +- .../near/GridCacheNearClientHitTest.java | 14 - .../near/GridCacheNearEvictionSelfTest.java | 12 - .../near/GridCacheNearMultiGetSelfTest.java | 27 +- .../near/GridCacheNearMultiNodeSelfTest.java | 14 - .../near/GridCacheNearOneNodeSelfTest.java | 2 - .../near/GridCacheNearOnlyTopologySelfTest.java | 12 +- .../GridCacheNearPartitionedClearSelfTest.java | 12 - .../near/GridCacheNearReadersSelfTest.java | 12 - .../near/GridCacheNearTxForceKeyTest.java | 8 - .../near/GridCacheNearTxMultiNodeSelfTest.java | 12 - .../near/GridCacheNearTxPreloadSelfTest.java | 2 - ...AffinityExcludeNeighborsPerformanceTest.java | 12 - .../GridCachePartitionedAffinitySelfTest.java | 11 - ...ePartitionedBasicStoreMultiNodeSelfTest.java | 12 - .../near/GridCachePartitionedEventSelfTest.java | 2 - .../GridCachePartitionedEvictionSelfTest.java | 12 - ...titionedExplicitLockNodeFailureSelfTest.java | 12 - ...GridCachePartitionedFilteredPutSelfTest.java | 19 - .../GridCachePartitionedFullApiSelfTest.java | 3 - ...idCachePartitionedHitsAndMissesSelfTest.java | 11 - .../GridCachePartitionedLoadCacheSelfTest.java | 12 - ...achePartitionedMultiNodeCounterSelfTest.java | 12 - ...achePartitionedMultiNodeFullApiSelfTest.java | 3 - ...ePartitionedMultiThreadedPutGetSelfTest.java | 12 - .../GridCachePartitionedStorePutSelfTest.java | 19 - ...CachePartitionedTxMultiThreadedSelfTest.java | 12 - .../GridCachePartitionedTxSalvageSelfTest.java | 13 - ...achePartitionedTxSingleThreadedSelfTest.java | 12 - .../near/GridPartitionedBackupLoadSelfTest.java | 19 - .../near/IgniteCacheNearOnlyTxTest.java | 2 - .../near/IgniteCacheNearReadCommittedTest.java | 2 - .../near/NearCacheMultithreadedUpdateTest.java | 8 - .../near/NearCachePutAllMultinodeTest.java | 12 - .../near/NearCacheSyncUpdateTest.java | 20 +- .../rebalancing/CacheManualRebalancingTest.java | 7 - ...cingDelayedPartitionMapExchangeSelfTest.java | 5 - .../GridCacheRebalancingCancelTest.java | 8 - .../GridCacheRebalancingSyncCheckDataTest.java | 8 - .../GridCacheRebalancingSyncSelfTest.java | 6 - ...eRebalancingUnmarshallingFailedSelfTest.java | 5 - ...cheRebalancingWithAsyncClearingMvccTest.java | 2 + ...balanceOnCachesStoppingOrDestroyingTest.java | 21 +- ...ridCacheReplicatedMultiNodeLockSelfTest.java | 4 +- .../GridCacheReplicatedMultiNodeSelfTest.java | 4 +- .../GridCacheSyncReplicatedPreloadSelfTest.java | 16 +- .../GridCacheReplicatedPreloadSelfTest.java | 15 +- ...eplicatedPreloadStartStopEventsSelfTest.java | 8 - .../cache/eviction/EvictionAbstractTest.java | 12 - .../EvictionPolicyFactoryAbstractTest.java | 12 - ...heConcurrentEvictionConsistencySelfTest.java | 12 - .../GridCacheConcurrentEvictionsSelfTest.java | 12 - .../GridCacheEmptyEntriesAbstractSelfTest.java | 12 - .../GridCacheEvictionFilterSelfTest.java | 12 - .../GridCacheEvictionLockUnlockSelfTest.java | 12 - .../GridCacheEvictionTouchSelfTest.java | 12 - .../lru/LruNearEvictionPolicySelfTest.java | 18 +- .../LruNearOnlyNearEvictionPolicySelfTest.java | 16 +- .../paged/PageEvictionAbstractTest.java | 8 - .../PageEvictionMultinodeAbstractTest.java | 4 +- .../IgniteCacheExpiryPolicyTestSuite.java | 5 +- .../expiry/IgniteCacheLargeValueExpireTest.java | 8 - .../IgniteCacheLoadAllAbstractTest.java | 2 - .../IgniteCacheTxLoaderWriterTest.java | 2 - .../IgniteCacheTxLocalLoadAllTest.java | 2 - ...niteCacheTxLocalNoLoadPreviousValueTest.java | 2 - .../IgniteCacheTxLocalNoReadThroughTest.java | 2 - .../IgniteCacheTxLocalNoWriteThroughTest.java | 2 - ...cheTxNearEnabledNoLoadPreviousValueTest.java | 2 - ...iteCacheTxNearEnabledNoWriteThroughTest.java | 2 - .../IgniteCacheTxNoLoadPreviousValueTest.java | 2 - .../IgniteCacheTxNoReadThroughTest.java | 2 - .../IgniteCacheTxNoWriteThroughTest.java | 2 - .../IgniteCacheTxStoreSessionTest.java | 2 - ...TxStoreSessionWriteBehindCoalescingTest.java | 2 - ...gniteCacheTxStoreSessionWriteBehindTest.java | 2 - .../local/GridCacheLocalBasicApiSelfTest.java | 2 - .../local/GridCacheLocalBasicStoreSelfTest.java | 2 - .../GridCacheLocalEvictionEventSelfTest.java | 2 - ...dCacheLocalGetAndTransformStoreSelfTest.java | 2 - .../local/GridCacheLocalLoadAllSelfTest.java | 2 - .../cache/local/GridCacheLocalLockSelfTest.java | 2 - .../GridCacheLocalMultithreadedSelfTest.java | 2 - .../local/GridCacheLocalTxTimeoutSelfTest.java | 2 - ...acheMvccAbstractCoordinatorFailoverTest.java | 7 +- .../cache/mvcc/CacheMvccAbstractTest.java | 11 +- .../cache/mvcc/CacheMvccClusterRestartTest.java | 8 - .../CacheMvccConfigurationValidationTest.java | 54 +- ...eMvccPartitionedCoordinatorFailoverTest.java | 9 + .../cache/mvcc/CacheMvccTransactionsTest.java | 15 +- .../cache/mvcc/CacheMvccTxFailoverTest.java | 6 - .../CheckpointReadLockFailureTest.java | 127 ++++ .../IgniteDataStorageMetricsSelfTest.java | 8 - .../IgnitePdsBinarySortObjectFieldsTest.java | 8 - ...gnitePdsCacheAssignmentNodeRestartsTest.java | 8 - ...heConfigurationFileConsistencyCheckTest.java | 10 +- ...cheObjectBinaryProcessorOnDiscoveryTest.java | 10 +- .../IgnitePdsCacheRebalancingAbstractTest.java | 11 - ...dsContinuousRestartTestWithExpiryPolicy.java | 9 - ...ousRestartTestWithSharedGroupAndIndexes.java | 9 - .../IgnitePdsDestroyCacheAbstractTest.java | 10 +- .../IgnitePdsExchangeDuringCheckpointTest.java | 12 - ...gnitePdsRecoveryAfterFileCorruptionTest.java | 11 - .../IgnitePdsRemoveDuringRebalancingTest.java | 11 - .../IgnitePersistentStoreCacheGroupsTest.java | 8 - ...IgnitePersistentStoreDataStructuresTest.java | 8 - ...teRebalanceScheduleResendPartitionsTest.java | 7 - ...hangeDuringRebalanceOnNonNodeAssignTest.java | 8 - .../db/CheckpointBufferDeadlockTest.java | 8 - .../db/CheckpointFailingIoFactory.java | 88 +++ .../db/IgniteLogicalRecoveryTest.java | 36 +- .../db/IgnitePdsCacheRestoreTest.java | 8 - .../db/IgnitePdsDataRegionMetricsTest.java | 12 +- .../db/IgnitePdsMultiNodePutGetRestartTest.java | 8 - .../db/IgnitePdsPageEvictionTest.java | 11 - .../db/IgnitePdsPartitionPreloadTest.java | 9 +- .../db/IgnitePdsReserveWalSegmentsTest.java | 8 - .../db/IgnitePdsTransactionsHangTest.java | 10 - .../persistence/db/IgnitePdsWithTtlTest.java | 10 - .../IgniteSequentialNodeCrashRecoveryTest.java | 339 +++++++++++ ...SlowHistoricalRebalanceSmallHistoryTest.java | 11 - ...faultPageSizeBackwardsCompatibilityTest.java | 9 - .../db/file/IgnitePdsCacheIntegrationTest.java | 8 - ...ckpointSimulationWithRealCpDisabledTest.java | 12 - .../wal/FsyncWalRolloverDoesNotBlockTest.java | 8 - .../IgniteNodeStoppedDuringDisableWALTest.java | 8 - ...IsReachedDuringIterationOverArchiveTest.java | 8 - ...gniteWalIteratorExceptionDuringReadTest.java | 8 - .../db/wal/IgniteWalSerializerVersionTest.java | 8 - .../db/wal/WalCompactionAfterRestartTest.java | 8 - .../db/wal/WalCompactionSwitchOnTest.java | 144 +++++ .../persistence/db/wal/WalCompactionTest.java | 17 +- .../db/wal/WalRolloverRecordLoggingTest.java | 8 - .../db/wal/WalRolloverTypesTest.java | 8 - ...IgniteAbstractWalIteratorInvalidCrcTest.java | 7 - .../db/wal/crc/IgniteDataIntegrityTests.java | 19 +- .../wal/crc/IgnitePureJavaCrcCompatibility.java | 8 +- .../db/wal/reader/IgniteWalReaderTest.java | 8 - .../metastorage/IgniteMetaStorageBasicTest.java | 15 +- .../pagemem/FillFactorMetricTest.java | 6 - .../persistence/pagemem/NoOpWALManager.java | 5 + .../pagemem/PagesWriteThrottleSandboxTest.java | 9 - .../pagemem/PagesWriteThrottleSmokeTest.java | 9 - .../AbstractNodeJoinTemplate.java | 9 - .../IgniteNoParrallelClusterIsAllowedTest.java | 5 - .../IgniteStandByClusterTest.java | 8 - .../persistence/tree/io/TrackingPageIOTest.java | 11 +- .../wal/ExplicitWalDeltaConsistencyTest.java | 1 + .../persistence/wal/aware/SegmentAwareTest.java | 11 +- .../wal/memtracker/PageMemoryTracker.java | 12 +- .../StandaloneWalRecordsIteratorTest.java | 9 - .../GridCacheQueryTransformerSelfTest.java | 7 - .../cache/query/IndexingSpiQuerySelfTest.java | 8 - .../continuous/CacheContinuousBatchAckTest.java | 12 - ...heContinuousBatchForceServerModeAckTest.java | 37 +- ...eContinuousQueryAsyncFilterListenerTest.java | 8 - ...nuousQueryConcurrentPartitionUpdateTest.java | 10 +- ...CacheContinuousQueryCounterAbstractTest.java | 12 - ...usQueryFactoryFilterRandomOperationTest.java | 3 +- ...ContinuousQueryFailoverAbstractSelfTest.java | 6 - .../CacheContinuousQueryLostPartitionTest.java | 11 - ...ontinuousQueryOperationFromCallbackTest.java | 7 - .../CacheContinuousQueryOperationP2PTest.java | 8 - .../CacheContinuousQueryOrderingEventTest.java | 7 - ...acheContinuousQueryRandomOperationsTest.java | 10 +- ...heContinuousWithTransformerFailoverTest.java | 8 - ...eEntryProcessorExternalizableFailedTest.java | 20 +- .../CacheEntryProcessorNonSerializableTest.java | 21 +- ...CacheKeepBinaryIterationNearEnabledTest.java | 7 +- .../CacheKeepBinaryIterationTest.java | 7 - .../ContinuousQueryReassignmentTest.java | 16 - ...ridCacheContinuousQueryAbstractSelfTest.java | 12 - .../GridCacheContinuousQueryConcurrentTest.java | 8 - ...eContinuousQueryMultiNodesFilteringTest.java | 8 - ...dCacheContinuousQueryNodesFilteringTest.java | 8 - ...eContinuousQueryReplicatedTxOneNodeTest.java | 12 - ...niteCacheContinuousQueryBackupQueueTest.java | 8 - .../IgniteCacheContinuousQueryClientTest.java | 8 - ...eCacheContinuousQueryImmutableEntryTest.java | 8 - ...teCacheContinuousQueryNoUnsubscribeTest.java | 8 - .../GridCacheWriteBehindStoreAbstractTest.java | 2 - .../GridCacheWriteBehindStoreLocalTest.java | 2 - ...BehindStorePartitionedMultiNodeSelfTest.java | 12 - .../AbstractTransactionIntergrityTest.java | 8 - .../transactions/DepthFirstSearchTest.java | 9 +- .../cache/transactions/TxOnCachesStartTest.java | 16 - .../TxOptimisticDeadlockDetectionTest.java | 17 +- ...OptimisticPrepareOnUnstableTopologyTest.java | 12 - .../TxRollbackAsyncNearCacheTest.java | 2 - .../cache/transactions/TxRollbackAsyncTest.java | 7 - .../TxRollbackAsyncWithPersistenceTest.java | 12 + .../TxRollbackOnTimeoutOnePhaseCommitTest.java | 7 - .../transactions/TxRollbackOnTimeoutTest.java | 7 - .../TxRollbackOnTopologyChangeTest.java | 7 - ...WithSmallTimeoutAndContentionOneKeyTest.java | 8 - ...ersionedEntryLocalTransactionalSelfTest.java | 2 - .../closure/GridClosureProcessorSelfTest.java | 12 - ...ComputeJobExecutionErrorToLogManualTest.java | 20 - ...puteCustomExecutorConfigurationSelfTest.java | 19 - .../continuous/GridEventConsumeSelfTest.java | 12 - ...IgniteContinuousQueryMetadataUpdateTest.java | 129 +++++ .../IgniteNoCustomEventsOnNodeStart.java | 10 - .../database/IgniteDbAbstractTest.java | 11 - .../database/IgniteDbDynamicCacheSelfTest.java | 4 + .../DataStreamProcessorMvccSelfTest.java | 21 +- .../DataStreamProcessorSelfTest.java | 12 - ...rClientReconnectAfterClusterRestartTest.java | 7 - .../datastreamer/DataStreamerImplSelfTest.java | 11 - .../DataStreamerMultiThreadedSelfTest.java | 11 - .../DataStreamerMultinodeCreateCacheTest.java | 7 - .../DataStreamerUpdateAfterLoadTest.java | 8 - .../IgniteDataStreamerPerformanceTest.java | 12 - .../igfs/IgfsDataManagerSelfTest.java | 12 - .../igfs/IgfsMetaManagerSelfTest.java | 12 - .../processors/igfs/IgfsMetricsSelfTest.java | 8 - .../igfs/IgfsModeResolverSelfTest.java | 14 +- .../processors/igfs/IgfsProcessorSelfTest.java | 13 - .../igfs/IgfsProcessorValidationSelfTest.java | 12 - ...IpcEndpointRegistrationAbstractSelfTest.java | 16 - .../processors/igfs/IgfsSizeSelfTest.java | 8 - .../processors/igfs/IgfsStartCacheTest.java | 12 - .../processors/igfs/IgfsStreamsSelfTest.java | 12 - .../processors/igfs/IgfsTaskSelfTest.java | 11 - .../IgfsAbstractRecordResolverSelfTest.java | 11 - .../service/ClosureServiceClientsNodesTest.java | 8 - .../service/GridServiceClientNodeTest.java | 8 - .../GridServiceProcessorAbstractSelfTest.java | 12 - ...GridServiceProcessorBatchDeploySelfTest.java | 24 +- ...GridServiceProxyClientReconnectSelfTest.java | 8 - .../GridServiceProxyNodeStopSelfTest.java | 16 - .../GridServiceSerializationSelfTest.java | 16 - ...yment2ClassLoadersDefaultMarshallerTest.java | 12 - ...oymentClassLoadingDefaultMarshallerTest.java | 12 - .../IgniteServiceDynamicCachesSelfTest.java | 20 - .../service/IgniteServiceReassignmentTest.java | 8 - .../ServiceDeploymentOnActivationTest.java | 10 - .../ServiceDeploymentOutsideBaselineTest.java | 10 - .../ServicePredicateAccessCacheTest.java | 8 - .../service/SystemCacheNotConfiguredTest.java | 11 - .../ignite/internal/util/GridCleanerTest.java | 6 +- ...dStartupWithUndefinedIgniteHomeSelfTest.java | 9 +- ...dUnsafeDataInputOutputByteOrderSelfTest.java | 15 +- .../IpcSharedMemoryNativeLoaderSelfTest.java | 9 +- .../nio/GridNioDelimitedBufferSelfTest.java | 8 +- .../internal/util/nio/GridRoundTripTest.java | 6 +- .../nio/IgniteExceptionInNioWorkerSelfTest.java | 10 - .../org/apache/ignite/jvmtest/FileIOTest.java | 6 +- .../apache/ignite/jvmtest/FileLocksTest.java | 6 +- .../ignite/jvmtest/LinkedHashMapTest.java | 6 +- .../ignite/jvmtest/NetworkFailureTest.java | 6 +- .../QueueSizeCounterMultiThreadedTest.java | 6 +- .../jvmtest/ReadWriteLockMultiThreadedTest.java | 6 +- .../org/apache/ignite/jvmtest/RegExpTest.java | 6 +- .../jvmtest/ServerSocketMultiThreadedTest.java | 6 +- .../loadtests/GridCacheMultiNodeLoadTest.java | 12 - .../communication/GridIoManagerBenchmark0.java | 12 - .../GridCachePartitionedAtomicLongLoadTest.java | 12 - .../ignite/logger/java/JavaLoggerTest.java | 8 +- .../GridMarshallerMappingConsistencyTest.java | 11 - .../ignite/messaging/GridMessagingSelfTest.java | 16 - .../messaging/IgniteMessagingSendAsyncTest.java | 16 - .../IgniteMessagingWithClientTest.java | 7 - .../GridP2PContinuousDeploymentSelfTest.java | 12 - .../p2p/GridP2PDoubleDeploymentSelfTest.java | 12 - .../GridP2PMissedResourceCacheSizeSelfTest.java | 12 - .../p2p/GridP2PSameClassLoaderSelfTest.java | 8 - .../services/ServiceThreadPoolSelfTest.java | 15 - .../CacheCheckpointSpiSecondCacheSelfTest.java | 12 - .../communication/GridCacheMessageSelfTest.java | 12 - .../tcp/GridCacheDhtLockBackupSelfTest.java | 12 - ...IgniteTcpCommunicationHandshakeWaitTest.java | 2 + .../tcp/TcpCommunicationSpiDropNodesTest.java | 10 - .../TcpCommunicationSpiFaultyClientTest.java | 11 +- .../tcp/TcpCommunicationStatisticsTest.java | 8 - .../FilterDataForClientNodeDiscoveryTest.java | 7 +- .../IgniteDiscoveryCacheReuseSelfTest.java | 16 - .../discovery/tcp/IgniteClientConnectTest.java | 10 +- ...gniteClientReconnectMassiveShutdownTest.java | 7 - ...pClientDiscoveryMarshallerCheckSelfTest.java | 9 - .../TcpDiscoveryClientSuspensionSelfTest.java | 11 - .../tcp/TcpDiscoveryConcurrentStartTest.java | 7 - .../TcpDiscoveryMarshallerCheckSelfTest.java | 11 - .../tcp/TcpDiscoveryMultiThreadedTest.java | 11 +- ...DiscoveryNodeConfigConsistentIdSelfTest.java | 7 - .../TcpDiscoveryNodeConsistentIdSelfTest.java | 7 - .../TcpDiscoveryPendingMessageDeliveryTest.java | 8 +- .../discovery/tcp/TcpDiscoveryRestartTest.java | 10 - .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 90 +++ .../tcp/TcpDiscoverySpiRandomStartStopTest.java | 12 - .../tcp/TcpDiscoverySpiWildcardSelfTest.java | 10 - .../vm/TcpDiscoveryVmIpFinderSelfTest.java | 16 +- .../KeystoreEncryptionSpiSelfTest.java | 9 +- .../stream/socket/SocketStreamerSelfTest.java | 12 - .../ignite/testframework/GridTestUtils.java | 52 +- .../ConfigVariationsTestSuiteBuilder.java | 22 +- .../IgniteConfigVariationsTestSuite.java | 50 -- .../configvariations/VariationsTestsConfig.java | 4 +- .../testframework/junits/GridAbstractTest.java | 114 ++-- .../IgniteConfigVariationsAbstractTest.java | 34 +- .../junits/JUnit3TestLegacySupport.java | 134 +++++ .../junits/common/GridAbstractExamplesTest.java | 3 - .../junits/common/GridCommonAbstractTest.java | 4 - .../junits/spi/GridSpiAbstractTest.java | 4 - .../ConfigVariationsTestSuiteBuilderTest.java | 39 +- .../testframework/test/ParametersTest.java | 8 +- .../test/VariationsIteratorTest.java | 9 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 11 +- .../IgniteBasicWithPersistenceTestSuite.java | 11 +- .../testsuites/IgniteBinaryCacheTestSuite.java | 5 +- .../IgniteBinaryObjectsCacheTestSuite3.java | 4 +- .../IgniteBinaryObjectsTestSuite.java | 5 +- ...iteBinarySimpleNameMapperBasicTestSuite.java | 5 +- ...rySimpleNameMapperCacheFullApiTestSuite.java | 8 +- ...heBasicConfigVariationsFullApiTestSuite.java | 8 +- ...eBlockExchangeOnReadOperationsTestSuite.java | 5 +- ...eCacheDataStructuresBinarySelfTestSuite.java | 21 +- .../IgniteCacheDataStructuresSelfTestSuite.java | 5 +- .../IgniteCacheEvictionSelfTestSuite.java | 5 +- .../IgniteCacheFailoverTestSuite.java | 5 +- .../IgniteCacheFailoverTestSuite2.java | 3 + .../IgniteCacheFailoverTestSuite3.java | 5 +- .../IgniteCacheFailoverTestSuiteSsl.java | 5 +- ...IgniteCacheFullApiMultiJvmSelfTestSuite.java | 5 +- .../IgniteCacheFullApiSelfTestSuite.java | 5 +- .../IgniteCacheIteratorsSelfTestSuite.java | 5 +- .../IgniteCacheLoadConsistencyTestSuite.java | 5 +- .../IgniteCacheMetricsSelfTestSuite.java | 6 +- .../testsuites/IgniteCacheMvccTestSuite.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite1.java | 14 +- .../testsuites/IgniteCacheMvccTestSuite2.java | 7 +- .../testsuites/IgniteCacheMvccTestSuite3.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite4.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite5.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite6.java | 5 +- .../testsuites/IgniteCacheMvccTestSuite7.java | 7 +- .../testsuites/IgniteCacheMvccTestSuite8.java | 8 +- .../testsuites/IgniteCacheMvccTestSuite9.java | 5 +- .../IgniteCacheNearOnlySelfTestSuite.java | 5 +- ...niteCacheP2pUnmarshallingErrorTestSuite.java | 13 +- .../testsuites/IgniteCacheRestartTestSuite.java | 5 +- .../IgniteCacheRestartTestSuite2.java | 5 +- .../IgniteCacheTcpClientDiscoveryTestSuite.java | 3 + .../ignite/testsuites/IgniteCacheTestSuite.java | 5 +- .../testsuites/IgniteCacheTestSuite2.java | 7 +- .../testsuites/IgniteCacheTestSuite3.java | 5 +- .../testsuites/IgniteCacheTestSuite4.java | 5 +- .../testsuites/IgniteCacheTestSuite5.java | 8 +- .../testsuites/IgniteCacheTestSuite6.java | 5 +- .../testsuites/IgniteCacheTestSuite7.java | 9 +- .../testsuites/IgniteCacheTestSuite8.java | 5 +- .../testsuites/IgniteCacheTestSuite9.java | 5 +- .../IgniteCacheTxRecoverySelfTestSuite.java | 5 +- .../IgniteCacheWriteBehindTestSuite.java | 7 +- .../testsuites/IgniteClientNodesTestSuite.java | 5 +- .../IgniteClientReconnectTestSuite.java | 5 +- ...teBasicConfigVariationsFullApiTestSuite.java | 8 +- .../testsuites/IgniteComputeGridTestSuite.java | 6 +- ...iteContinuousQueryConfigVariationsSuite.java | 8 +- .../IgniteContinuousTaskSelfTestSuite.java | 8 +- .../testsuites/IgniteDatabaseTestSuite.java | 5 +- .../testsuites/IgniteDbMemoryLeakTestSuite.java | 5 +- .../IgniteExternalizableSelfTestSuite.java | 5 +- .../ignite/testsuites/IgniteIgfsTestSuite.java | 5 +- .../IgniteIpcSharedMemorySelfTestSuite.java | 8 +- .../ignite/testsuites/IgniteIpcTestSuite.java | 5 +- .../IgniteJobMetricsSelfTestSuite.java | 8 +- .../testsuites/IgniteKernalSelfTestSuite.java | 5 +- .../testsuites/IgniteLangSelfTestSuite.java | 8 +- .../testsuites/IgniteLoggingSelfTestSuite.java | 5 +- .../testsuites/IgniteLostAndFoundTestSuite.java | 5 +- .../IgniteMarshallerSelfTestSuite.java | 11 +- ...essagingConfigVariationFullApiTestSuite.java | 8 +- .../testsuites/IgniteP2PSelfTestSuite.java | 11 +- .../testsuites/IgnitePdsMvccTestSuite.java | 5 +- .../testsuites/IgnitePdsMvccTestSuite2.java | 7 +- .../testsuites/IgnitePdsMvccTestSuite3.java | 7 +- .../testsuites/IgnitePdsMvccTestSuite4.java | 5 +- .../ignite/testsuites/IgnitePdsTestSuite.java | 5 +- .../ignite/testsuites/IgnitePdsTestSuite2.java | 7 +- .../ignite/testsuites/IgnitePdsTestSuite4.java | 5 +- .../testsuites/IgnitePerformanceTestSuite.java | 5 +- .../testsuites/IgnitePlatformsTestSuite.java | 8 +- .../testsuites/IgniteReproducingSuite.java | 8 +- .../testsuites/IgniteRestHandlerTestSuite.java | 5 +- ...ServiceConfigVariationsFullApiTestSuite.java | 10 +- .../IgniteSpiCheckpointSelfTestSuite.java | 8 +- .../IgniteSpiCollisionSelfTestSuite.java | 5 +- .../IgniteSpiCommunicationSelfTestSuite.java | 10 +- .../IgniteSpiDeploymentSelfTestSuite.java | 8 +- .../IgniteSpiDiscoverySelfTestSuite.java | 8 +- .../IgniteSpiEventStorageSelfTestSuite.java | 8 +- .../IgniteSpiFailoverSelfTestSuite.java | 8 +- .../IgniteSpiLoadBalancingSelfTestSuite.java | 3 + .../ignite/testsuites/IgniteSpiTestSuite.java | 5 +- .../testsuites/IgniteStandByClusterSuite.java | 5 +- .../testsuites/IgniteStartUpTestSuite.java | 8 +- .../testsuites/IgniteStreamSelfTestSuite.java | 8 +- .../IgniteTaskSessionSelfTestSuite.java | 8 +- .../IgniteTimeoutProcessorSelfTestSuite.java | 8 +- .../IgniteTopologyValidatorTestSuite.java | 5 +- .../testsuites/IgniteUtilSelfTestSuite.java | 5 +- ...orCacheConfigVariationsFullApiTestSuite.java | 8 +- .../TxDeadlockDetectionTestSuite.java | 5 +- ...ryCacheConfigVariationsFullApiTestSuite.java | 8 +- .../util/AttributeNodeFilterSelfTest.java | 8 - .../ignite/util/GridCommandHandlerTest.java | 123 ++-- .../apache/ignite/util/GridIntListSelfTest.java | 9 +- .../GridInternalTaskUnusedWalSegmentsTest.java | 8 - .../ignite/util/GridLongListSelfTest.java | 10 +- .../ignite/util/GridMessageCollectionTest.java | 8 +- .../util/GridTopologyHeapSizeSelfTest.java | 20 - .../util/mbeans/GridMBeanDisableSelfTest.java | 4 - ...lWalModeChangeDuringRebalancingSelfTest.java | 4 + .../persistence/file/IgniteFileIOTest.java | 6 +- .../testsuites/IgnitePdsNativeIoTestSuite.java | 5 +- .../testsuites/IgnitePdsNativeIoTestSuite2.java | 5 +- .../flink/FlinkIgniteSinkSelfTestSuite.java | 5 +- .../stream/flume/IgniteSinkTestSuite.java | 5 +- .../ignite/testsuites/IgniteGCETestSuite.java | 5 +- .../testsuites/GeoSpatialIndexingTestSuite.java | 5 +- .../hadoop/impl/igfs/IgfsEventsTestSuite.java | 5 +- .../igfs/IgfsNearOnlyMultiNodeSelfTest.java | 8 - .../IgniteHadoopFileSystemIpcCacheSelfTest.java | 11 - .../testsuites/IgniteHadoopTestSuite.java | 5 +- .../IgniteIgfsLinuxAndMacOSTestSuite.java | 5 +- .../hibernate/HibernateL2CacheSelfTest.java | 12 - .../IgniteBinaryHibernateTestSuite.java | 8 +- .../testsuites/IgniteHibernateTestSuite.java | 7 +- .../hibernate/HibernateL2CacheSelfTest.java | 12 - .../IgniteBinaryHibernate5TestSuite.java | 8 +- .../testsuites/IgniteHibernate5TestSuite.java | 5 +- .../cache/query/RegisteredQueryCursor.java | 65 +++ .../query/h2/DmlStatementsProcessor.java | 128 ++-- .../processors/query/h2/H2DatabaseType.java | 14 +- .../processors/query/h2/IgniteH2Indexing.java | 334 ++++++----- .../processors/query/h2/dml/DmlUtils.java | 43 +- .../query/h2/twostep/DistributedUpdateRun.java | 15 +- .../h2/twostep/GridReduceQueryExecutor.java | 66 +-- .../query/h2/twostep/ReduceQueryRun.java | 25 +- ...MetadataConcurrentUpdateWithIndexesTest.java | 6 +- ...CacheAbstractQueryDetailMetricsSelfTest.java | 12 - .../CacheAbstractQueryMetricsSelfTest.java | 12 - .../CacheBinaryKeyConcurrentQueryTest.java | 8 - .../cache/CacheIndexStreamerTest.java | 16 - .../CacheOffheapBatchIndexingBaseTest.java | 8 - .../cache/CacheQueryBuildValueTest.java | 8 - .../cache/CacheQueryFilterExpiredTest.java | 16 - .../cache/CacheQueryNewClientSelfTest.java | 16 - .../CacheRandomOperationsMultithreadedTest.java | 8 - ...CacheScanPartitionQueryFallbackSelfTest.java | 9 +- .../cache/CacheSqlQueryValueCopySelfTest.java | 8 - .../cache/DdlTransactionSelfTest.java | 11 - .../cache/GridCacheCrossCacheQuerySelfTest.java | 12 - .../cache/GridCacheDynamicLoadOnClientTest.java | 14 + .../cache/GridCacheFullTextQuerySelfTest.java | 12 - ...GridCacheLazyQueryPartitionsReleaseTest.java | 12 - .../cache/GridCacheOffHeapSelfTest.java | 12 - .../GridCacheOffheapIndexEntryEvictTest.java | 12 - .../cache/GridCacheOffheapIndexGetSelfTest.java | 12 - .../GridCacheQueryIndexDisabledSelfTest.java | 12 - .../GridCacheQuerySerializationSelfTest.java | 12 - .../cache/GridCacheQuerySimpleBenchmark.java | 12 - .../cache/GridIndexingWithNoopSwapSelfTest.java | 12 - .../IgniteBinaryObjectFieldsQuerySelfTest.java | 12 - .../IgniteBinaryObjectQueryArgumentsTest.java | 8 - .../IgniteCacheAbstractFieldsQuerySelfTest.java | 18 - ...niteCacheAbstractInsertSqlQuerySelfTest.java | 12 - .../cache/IgniteCacheAbstractQuerySelfTest.java | 48 +- .../IgniteCacheAbstractSqlDmlQuerySelfTest.java | 12 - .../IgniteCacheCollocatedQuerySelfTest.java | 12 - ...acheConfigurationPrimitiveTypesSelfTest.java | 20 - .../IgniteCacheCrossCacheJoinRandomTest.java | 10 - ...acheDistributedJoinCollocatedAndNotTest.java | 10 - ...acheDistributedJoinCustomAffinityMapper.java | 8 - .../IgniteCacheDistributedJoinNoIndexTest.java | 10 - ...ributedJoinPartitionedAndReplicatedTest.java | 14 +- ...CacheDistributedJoinQueryConditionsTest.java | 10 - .../cache/IgniteCacheDistributedJoinTest.java | 10 - ...cheDuplicateEntityConfigurationSelfTest.java | 20 - .../IgniteCacheFieldsQueryNoDataSelfTest.java | 12 - ...teCacheFullTextQueryNodeJoiningSelfTest.java | 16 +- .../cache/IgniteCacheGroupsSqlTest.java | 16 - .../IgniteCacheInsertSqlQuerySelfTest.java | 12 - ...PartitionedAndReplicatedCollocationTest.java | 10 - ...teCacheJoinPartitionedAndReplicatedTest.java | 18 +- ...IgniteCacheJoinQueryWithAffinityKeyTest.java | 8 - .../cache/IgniteCacheLargeResultSelfTest.java | 12 - ...niteCacheLockPartitionOnAffinityRunTest.java | 4 +- .../cache/IgniteCacheNoClassQuerySelfTest.java | 7 +- .../cache/IgniteCacheOffheapEvictQueryTest.java | 12 - .../cache/IgniteCacheOffheapIndexScanTest.java | 12 - ...hePartitionedQueryMultiThreadedSelfTest.java | 12 - ...IgniteCachePrimitiveFieldsQuerySelfTest.java | 12 - .../cache/IgniteCacheQueriesLoadTest1.java | 8 - .../cache/IgniteCacheQueryLoadSelfTest.java | 12 - .../IgniteCacheQueryMultiThreadedSelfTest.java | 12 - ...gniteCacheSqlQueryMultiThreadedSelfTest.java | 12 - .../cache/IgniteCacheUnionDuplicatesTest.java | 5 + ...CheckClusterStateBeforeExecuteQueryTest.java | 9 - .../cache/IgniteCrossCachesJoinsQueryTest.java | 8 - .../cache/IgniteErrorOnRebalanceTest.java | 8 - .../authentication/SqlUserCommandSelfTest.java | 12 - .../distributed/CacheBlockOnSqlQueryTest.java | 32 +- ...lientQueryReplicatedNodeRestartSelfTest.java | 12 - ...stributedPartitionQueryAbstractSelfTest.java | 10 - ...niteCacheDistributedQueryCancelSelfTest.java | 7 - ...butedQueryStopOnCancelOrTimeoutSelfTest.java | 7 - .../IgniteCachePartitionedQuerySelfTest.java | 4 + ...cheQueryAbstractDistributedJoinSelfTest.java | 12 - .../IgniteCacheQueryNoRebalanceSelfTest.java | 8 - .../near/IgniteCacheQueryNodeFailTest.java | 8 - .../IgniteCacheQueryNodeRestartSelfTest.java | 12 - .../IgniteCacheQueryNodeRestartSelfTest2.java | 12 - .../near/IgniteSqlQueryWithBaselineTest.java | 12 - .../IgniteCacheReplicatedQuerySelfTest.java | 12 + .../cache/index/AbstractSchemaSelfTest.java | 8 - .../processors/cache/index/BasicIndexTest.java | 11 +- .../cache/index/DynamicColumnsAbstractTest.java | 8 - .../index/DynamicIndexAbstractSelfTest.java | 8 - .../index/IoStatisticsBasicIndexSelfTest.java | 10 - .../index/MvccEmptyTransactionSelfTest.java | 7 - .../cache/index/SchemaExchangeSelfTest.java | 7 - ...sactionsCommandsWithMvccEnabledSelfTest.java | 4 +- ...acheMvccAbstractContinuousQuerySelfTest.java | 10 +- ...eMvccAbstractSqlCoordinatorFailoverTest.java | 7 + .../mvcc/CacheMvccBackupsAbstractTest.java | 5 +- .../mvcc/CacheMvccBasicContinuousQueryTest.java | 3 + ...eMvccContinuousQueryClientReconnectTest.java | 16 + .../CacheMvccContinuousQueryClientTest.java | 9 + ...ContinuousWithTransformerClientSelfTest.java | 4 +- ...nuousWithTransformerPartitionedSelfTest.java | 4 +- ...inuousWithTransformerReplicatedSelfTest.java | 4 +- ...ccPartitionedSqlCoordinatorFailoverTest.java | 8 + ...eMvccReplicatedSelectForUpdateQueryTest.java | 2 +- .../CacheMvccReplicatedSqlTxQueriesTest.java | 2 + .../mvcc/CacheMvccSqlQueriesAbstractTest.java | 7 + .../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 5 +- ...MvccSqlTxQueriesWithReducerAbstractTest.java | 2 + .../cache/mvcc/CacheMvccTxRecoveryTest.java | 2 + .../db/wal/IgniteWalRecoveryTest.java | 2 - .../cache/ttl/CacheTtlAbstractSelfTest.java | 8 - ...oreQueryWithMultipleClassesPerCacheTest.java | 8 - .../IgnitePersistentStoreSchemaLoadTest.java | 8 - .../query/IgniteCachelessQueriesSelfTest.java | 12 - .../query/IgniteQueryDedicatedPoolTest.java | 9 - .../query/IgniteSqlDefaultValueTest.java | 11 +- .../query/IgniteSqlDistributedJoinSelfTest.java | 12 - .../IgniteSqlEntryCacheModeAgnosticTest.java | 12 - .../IgniteSqlGroupConcatCollocatedTest.java | 12 - .../IgniteSqlGroupConcatNotCollocatedTest.java | 12 - .../query/IgniteSqlKeyValueFieldsTest.java | 12 - .../query/IgniteSqlNotNullConstraintTest.java | 12 - .../query/IgniteSqlParameterizedQueryTest.java | 11 - .../query/IgniteSqlQueryParallelismTest.java | 12 - .../processors/query/IgniteSqlRoutingTest.java | 11 - .../query/IgniteSqlSchemaIndexingTest.java | 20 +- .../query/IgniteSqlSegmentedIndexSelfTest.java | 12 - ...teSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 11 - ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 11 - .../query/IgniteSqlSplitterSelfTest.java | 17 +- .../processors/query/RunningQueriesTest.java | 578 ++++++++++++++++++- ...cheQueryEntityWithDateTimeApiFieldsTest.java | 405 +++++++++++++ .../query/h2/IgniteSqlQueryMinMaxTest.java | 9 - .../h2/sql/AbstractH2CompareQueryTest.java | 12 - .../query/h2/sql/GridQueryParsingTest.java | 12 - .../AndOperationExtractPartitionSelfTest.java | 5 + .../h2/twostep/CacheQueryMemoryLeakTest.java | 7 - .../h2/twostep/RetryCauseMessageSelfTest.java | 4 +- ...ansactionalSnapshotColumnConstraintTest.java | 55 +- ...ansactionalSnapshotColumnConstraintTest.java | 55 +- .../tcp/GridOrderedMessageCancelSelfTest.java | 12 - .../ignite/sqltests/ReplicatedSqlTest.java | 13 +- .../IgniteBinaryCacheQueryTestSuite.java | 462 +++++++-------- .../IgniteBinaryCacheQueryTestSuite2.java | 8 +- ...narySimpleNameMapperCacheQueryTestSuite.java | 8 +- .../IgniteCacheAffinityRunTestSuite.java | 5 +- ...ockExchangeOnSqlReadOperationsTestSuite.java | 5 +- ...gniteCacheConfigVariationQueryTestSuite.java | 8 +- .../testsuites/IgniteCacheMvccSqlTestSuite.java | 14 +- .../IgniteCacheQuerySelfTestSuite3.java | 5 +- .../IgniteCacheQuerySelfTestSuite4.java | 5 +- .../IgniteCacheQuerySelfTestSuite5.java | 5 +- .../IgniteCacheQuerySelfTestSuite6.java | 5 +- ...acheWithIndexingAndPersistenceTestSuite.java | 5 +- .../IgniteCacheWithIndexingTestSuite.java | 5 +- ...IgniteDbMemoryLeakWithIndexingTestSuite.java | 5 +- .../IgnitePdsWithIndexingCoreTestSuite.java | 8 +- .../IgnitePdsWithIndexingTestSuite.java | 5 +- .../util/GridCommandHandlerIndexingTest.java | 6 +- ...ityWithJsr310Java8DateTimeApiFieldsTest.java | 363 ------------ ...QueryJsr310Java8DateTimeApiAbstractTest.java | 88 --- ...yJsr310Java8DateTimeApiSupportTestSuite.java | 39 -- .../apache/ignite/logger/jcl/JclLoggerTest.java | 6 +- .../ignite/testsuites/IgniteJclTestSuite.java | 5 +- .../cache/jta/AbstractCacheJtaSelfTest.java | 7 + .../ignite/testsuites/IgniteJtaTestSuite.java | 13 +- .../kafka/IgniteKafkaStreamerSelfTestSuite.java | 5 +- .../testsuites/IgniteKubernetesTestSuite.java | 5 +- .../logger/log4j/GridLog4jConfigUpdateTest.java | 9 +- .../log4j/GridLog4jCorrectFileNameTest.java | 14 +- .../logger/log4j/GridLog4jInitializedTest.java | 17 +- .../logger/log4j/GridLog4jLoggingFileTest.java | 10 +- .../logger/log4j/GridLog4jLoggingPathTest.java | 10 +- .../logger/log4j/GridLog4jLoggingUrlTest.java | 10 +- .../log4j/GridLog4jNotInitializedTest.java | 8 +- .../logger/log4j2/Log4j2ConfigUpdateTest.java | 9 +- .../log4j2/Log4j2LoggerVerboseModeSelfTest.java | 15 +- .../testsuites/IgniteLog4j2TestSuite.java | 5 +- .../org/apache/ignite/IgniteMesosTestSuite.java | 5 +- .../ignite/mesos/IgniteSchedulerSelfTest.java | 29 +- .../BinaryClassificationEvaluator.java | 8 +- .../metric/BinaryClassificationMetrics.java | 25 +- .../org/apache/ignite/ml/IgniteMLTestSuite.java | 2 +- .../ignite/ml/dataset/DatasetTestSuite.java | 11 +- .../cache/CacheBasedDatasetBuilderTest.java | 6 + .../impl/cache/CacheBasedDatasetTest.java | 6 + .../impl/cache/util/ComputeUtilsTest.java | 5 + .../ignite/ml/inference/InferenceTestSuite.java | 7 +- .../IgniteDistributedInfModelBuilderTest.java | 2 + .../org/apache/ignite/ml/nn/MLPTestSuite.java | 7 +- .../ignite/ml/nn/MLPTrainerIntegrationTest.java | 7 + .../MLPTrainerMnistIntegrationTest.java | 5 + .../ignite/ml/selection/SelectionTestSuite.java | 9 +- .../ml/selection/cv/CrossValidationTest.java | 42 ++ .../cursor/CacheBasedLabelPairCursorTest.java | 5 + .../scoring/evaluator/EvaluatorTest.java | 7 + ...reeClassificationTrainerIntegrationTest.java | 5 + ...ionTreeRegressionTrainerIntegrationTest.java | 5 + .../ignite/ml/tree/DecisionTreeTestSuite.java | 9 +- .../DecisionTreeMNISTIntegrationTest.java | 5 + .../protocols/http/jetty/GridRestSuite.java | 5 +- .../rocketmq/RocketMQStreamerTestSuite.java | 5 +- .../testsuites/IgniteSchedulerTestSuite.java | 5 +- .../logger/slf4j/Slf4jLoggerMarkerTest.java | 22 +- .../ignite/testsuites/IgniteSlf4jTestSuite.java | 5 +- .../spark/JavaEmbeddedIgniteRDDSelfTest.java | 9 - .../ignite/testsuites/IgniteRDDTestSuite.java | 5 +- .../testsuites/IgniteSpringData2TestSuite.java | 5 +- .../testsuites/IgniteSpringDataTestSuite.java | 5 +- .../spring/GridSpringCacheManagerSelfTest.java | 12 - .../jdbc/CacheJdbcBlobStoreFactorySelfTest.java | 4 +- .../jdbc/CacheJdbcPojoStoreFactorySelfTest.java | 4 +- .../ignite/internal/GridFactorySelfTest.java | 14 - .../GridSpringBeanSerializationSelfTest.java | 12 - .../p2p/GridP2PUserVersionChangeSelfTest.java | 12 - .../testsuites/IgniteResourceSelfTestSuite.java | 5 +- .../testsuites/IgniteSpringTestSuite.java | 8 +- .../GridSpringTransactionManagerSelfTest.java | 12 - .../storm/IgniteStormStreamerSelfTestSuite.java | 5 +- modules/twitter/pom.xml | 2 +- .../twitter/IgniteTwitterStreamerTest.java | 61 +- .../twitter/IgniteTwitterStreamerTestSuite.java | 5 +- .../uri/GridUriDeploymentMd5CheckSelfTest.java | 2 +- .../testsuites/IgniteToolsSelfTestSuite.java | 5 +- .../IgniteWebSessionSelfTestSuite.java | 5 +- .../config/vendors/ignite-config-inmemory.xml | 75 +++ .../vendors/ignite-config-persistence.xml | 75 +++ .../ignite-jdbc-thin-select-all.properties | 105 ++++ .../vendors/ignite-jdbc-thin-select.properties | 109 ++++ .../vendors/mysql-jdbc-select-all.properties | 91 +++ .../config/vendors/mysql-jdbc-select.properties | 86 +++ .../vendors/postgre-jdbc-select-all.properties | 90 +++ .../vendors/postgre-jdbc-select.properties | 86 +++ .../IgniteCacheRandomOperationBenchmark.java | 86 +-- .../yardstick/jdbc/AbstractJdbcBenchmark.java | 9 +- .../jdbc/vendors/BaseSelectRangeBenchmark.java | 342 +++++++++++ .../yardstick/jdbc/vendors/QueryFactory.java | 127 ++++ .../jdbc/vendors/ScanAllBenchmark.java | 39 ++ .../jdbc/vendors/ScanAllWithJoinBenchmark.java | 39 ++ .../jdbc/vendors/SelectByPkBenchmark.java | 39 ++ .../vendors/SelectByPkWithJoinBenchmark.java | 39 ++ .../jdbc/vendors/SelectBySalaryBenchmark.java | 36 ++ .../SelectBySalaryWithJoinBenchmark.java | 36 ++ .../org/apache/ignite/IgniteYarnTestSuite.java | 5 +- .../yarn/IgniteApplicationMasterSelfTest.java | 3 +- .../zeromq/IgniteZeroMqStreamerTestSuite.java | 5 +- .../spi/discovery/zk/ZookeeperDiscoverySpi.java | 9 +- .../zk/ZookeeperDiscoverySpiMBean.java | 8 + .../zk/internal/ZookeeperDiscoveryImpl.java | 5 + .../internal/ZookeeperDiscoveryStatistics.java | 21 +- .../zk/ZookeeperDiscoverySpiTestSuite1.java | 5 +- .../zk/internal/ZookeeperDiscoverySpiTest.java | 111 +++- parent/pom.xml | 4 +- 1192 files changed, 7712 insertions(+), 10592 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/62aa742a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheMultiNodeLockAbstractTest.java ---------------------------------------------------------------------- diff --cc modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheMultiNodeLockAbstractTest.java index fed3342,5d6987f..73bfccf --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheMultiNodeLockAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheMultiNodeLockAbstractTest.java @@@ -31,13 -31,10 +31,10 @@@ import org.apache.ignite.configuration. import org.apache.ignite.events.CacheEvent; import org.apache.ignite.events.Event; import org.apache.ignite.internal.IgniteKernal; -import org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheAdapter; -import org.apache.ignite.internal.processors.cache.distributed.near.GridNearCacheAdapter; +import org.apache.ignite.internal.util.lang.GridAbsPredicate; import org.apache.ignite.lang.IgnitePredicate; - import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; - import org.apache.ignite.spi.discovery.tcp.ipfinder.TcpDiscoveryIpFinder; - import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; import org.apache.ignite.testframework.GridTestThread; +import org.apache.ignite.testframework.GridTestUtils; import org.apache.ignite.testframework.MvccFeatureChecker; import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest; import org.jetbrains.annotations.Nullable; http://git-wip-us.apache.org/repos/asf/ignite/blob/62aa742a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/distributed/GridCacheNodeFailureAbstractTest.java ----------------------------------------------------------------------