This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a change to branch ignite-28223
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 34ae7aee760 IGNITE-28223 fix code style
add 3df1cab8922 IGNITE-28085 Add the EvictionsStarted metric to
DataRegionMetrics (#12866)
add 5fb65a9440d IGNITE-27951: Upgrade Jetty to 11.0.25 and
tomcat-servlet-api to 10.0.27 (#12796)
add 81dda2275ca IGNITE-28203 Use MarshalableMessage for ErrorMessage
(#12878)
add e79d372fbe5 IGNITE-26959: Fix thin client continuous query cleanup on
disconnect (#12861)
add 53cde36b68f IGNITE-25793 Fix missing logs for
GridDhtPartitionsSingleMessage sending errors (#12161)
add 5248d977e92 IGNITE-27853 Use MessageSerializer fo
GridCacheRawVersionedEntry and DataStreamerEntry (#12746)
add 86c7e197c07 IGNITE-28189 Fixed incorrect status of a Compute Task when
it is canceled (#12876)
add c4f0cf089bf IGNITE-28114 Remove custom configuration for Apache RAT
plugin (#12871)
add b5da39c54a8 IGNITE-28211 Fixed flaky RestProcessorInitializationTest
(#12882)
add f6dacaaf29b IGNITE-27971 Use message serializer for
MappingAcceptedMessage and MappingProposedMessage (#12811)
add f88fd694705 IGNITE-28231 Add warning for `protected classes` CI job
and update comment (#12897)
add 907dfd8e2e0 IGNITE-28133 Fix failure on concurrent cache.get() and the
page eviction - Fixes #12884.
add 202b1fc8344 IGNITE-28186 DeploymentSPI marked as deprecated (#12874)
add 65d1cbe81a6 IGNITE-28246 Fix NPE in GridMarshallerMappingProcessor
(#12898)
add cc8c96f396d IGNITE-28220 : Revise serialization of
GridDeploymentRequest v2 (#12888)
add 64fa8a9504b IGNITE-27559 Use MessageSerializer for
SchemaAbstractOperation and successors (#12881)
add 04c41beca34 IGNITE-27556 : MessageSerializer for
TcpDiscoveryNodeAddedMessage v2 simplified (#12790)
add 5a2372a4712 IGNITE-28281 Split calcite suite to achieve 30 min per
suite run (#12905)
add 2c9e07b095c IGNITE-19972 Added metrics of snapshot check (#12330)
add 6cca09c3e79 IGNITE-28253 Removed redundant map keys from
IncrementalSnapshotVerifyResult message (#12900)
add c010a8623bc IGNITE-28255 Fix NotSerializableException:
org.apache.ignite.internal.processors.marshaller.MarshallerMappingItem (#12901)
add 2e7f9a7a95d IGNITE-28290 Added utility discovery collection message
(#12890)
add ef685f5c312 IGNITE-28243 Keep service descriptor even if no
deployments (#12910)
add 1b738b26390 IGNITE-28297 Update a comment for `protected classes` CI
job (#12914)
add 737c550270f IGNITE-28286 : Use MarshallableMessage for GridIoMessage
and GridEventStorageMessage v2 (#12891)
add b72bcacf8e1 IGNITE-28237: Finalize Mockito 5 migration and fix
incompatible tests (#12902)
add e149edcf34b IGNITE-27631 Use MessageSerializer for SingleNodeMessage
(#12827)
add 4cb61ce1aab IGNITE-27934 Fix flaky
GridBinaryAffinityKeySelfTest#testAffinity (#12896)
add 08a8afc2f2b IGNITE-28317: Add sanity check to forbid internal Mockito
API usage (#12918)
add 822c90bcde6 IGNITE-28232 Get rid of @Order method feature (#12889)
add 8eda6173fb8 IGNITE-28052 Use MessageSerializer for InitMessage (#12912)
add 09857d4f06d IGNITE-28222 Fixed race condition during Communication
Node Client creation (#12885)
add f66f416052e Merge branch 'master' into ignite-28223
add a7233078381 IGNITE-28223 Fix after review vpyatkov #1.0
add eacf0ee290c IGNITE-28223 Fix after review vpyatkov #1.1
No new revisions were added by this update.
Summary of changes:
.github/workflows/check-protected-classes.yml | 28 +-
checkstyle/checkstyle.xml | 6 +
docs/_docs/monitoring-metrics/new-metrics.adoc | 1 +
.../query/calcite/CalciteQueryProcessor.java | 35 ++
.../query/calcite/exec/ddl/DdlCommandHandler.java | 23 +-
.../query/calcite/message/CalciteErrorMessage.java | 36 +-
.../query/calcite/metadata/ColocationGroup.java | 26 +-
.../calcite/metadata/FragmentDescription.java | 17 +-
.../query/calcite/metadata/FragmentMapping.java | 18 +-
.../query/calcite/prepare/IgniteSqlValidator.java | 4 +-
.../calcite/schema/CacheTableDescriptorImpl.java | 4 +-
.../schema/PseudoCacheColumnDescriptor.java | 46 ++-
.../integration/PseudoColumnProviderTest.java | 38 ---
.../PseudoColumnProviderWithNodeRestartTest.java | 151 +++++++++
.../ignite/testsuites/IgniteCalciteTestSuite.java | 5 -
.../testsuites/IgniteCalciteTestSuite2.java} | 11 +-
.../testsuites/IgniteCalciteTestSuite3.java} | 7 +-
.../ignite/testsuites/IntegrationTestSuite.java | 4 +-
.../apache/ignite/internal/MessageProcessor.java | 2 -
.../internal/MessageSerializerGenerator.java | 116 ++++---
.../java/org/apache/ignite/internal/Order.java | 4 -
modules/core/pom.xml | 14 +
.../java/org/apache/ignite/DataRegionMetrics.java | 7 +
.../ignite/configuration/DeploymentMode.java | 4 +
.../ignite/configuration/IgniteConfiguration.java | 12 +
.../java/org/apache/ignite/internal/GridTopic.java | 20 +-
.../ignite/internal/MarshallerContextImpl.java | 2 -
.../cache/query/index/IndexKeyTypeMessage.java | 24 +-
.../managers/communication/ErrorMessage.java | 82 +----
.../managers/communication/GridIoManager.java | 26 +-
.../managers/communication/GridIoMessage.java | 23 +-
.../communication/GridIoMessageFactory.java | 98 +++++-
.../deployment/GridDeploymentCommunication.java | 30 +-
.../managers/deployment/GridDeploymentRequest.java | 81 ++---
.../discovery/DiscoveryMessageFactory.java | 159 +++++++--
.../SecurityAwareCustomMessageWrapper.java | 49 +--
.../encryption/ChangeCacheEncryptionRequest.java | 35 +-
.../managers/encryption/GridEncryptionManager.java | 94 +-----
.../managers/encryption/GroupKeyChangeProcess.java | 18 +-
.../encryption/MasterKeyChangeRequest.java | 107 ++++++
.../eventstorage/GridEventStorageManager.java | 19 +-
.../eventstorage/GridEventStorageMessage.java | 53 ++-
.../cache/CacheEntryPredicateAdapter.java | 75 ++++-
.../processors/cache/GridCacheAdapter.java | 2 -
.../processors/cache/GridCacheMessage.java | 2 +-
.../cache/GridCachePartitionExchangeManager.java | 6 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 13 +-
.../internal/processors/cache/StoredCacheData.java | 2 +
.../dht/PartitionUpdateCountersMessage.java | 33 +-
.../dht/preloader/GridDhtPartitionMap.java | 86 +----
.../preloader/GridDhtPartitionsExchangeFuture.java | 25 +-
.../preloader/GridDhtPartitionsFullMessage.java | 32 +-
.../preloader/IgniteDhtDemandedPartitionsMap.java | 14 +-
.../distributed/near/GridNearGetResponse.java | 2 +-
.../near/GridNearSingleGetResponse.java | 9 +-
.../cache/persistence/DataRegionMetricsImpl.java | 18 +
.../persistence/DataRegionMetricsSnapshot.java | 9 +
.../IgniteCacheDatabaseSharedManager.java | 2 +
.../evict/FairFifoPageEvictionTracker.java | 9 +-
.../persistence/evict/NoOpPageEvictionTracker.java | 9 +-
.../evict/PageAbstractEvictionTracker.java | 8 +-
.../persistence/evict/PageEvictionTracker.java | 9 +-
.../evict/Random2LruPageEvictionTracker.java | 37 ++-
.../evict/RandomLruPageEvictionTracker.java | 26 +-
.../snapshot/AbstractSnapshotOperationRequest.java | 36 +-
.../snapshot/DataStreamerUpdatesHandler.java | 11 +-
....java => DataStreamerUpdatesHandlerResult.java} | 42 +--
.../snapshot/IgniteSnapshotManager.java | 80 +----
.../snapshot/IncrementalSnapshotVerify.java | 42 ++-
.../snapshot/IncrementalSnapshotVerifyResult.java | 67 ++--
...java => SnapshotCheckHandlersNodeResponse.java} | 43 +--
...age.java => SnapshotCheckHandlersResponse.java} | 44 +--
.../SnapshotCheckPartitionHashesResponse.java | 69 ++++
.../persistence/snapshot/SnapshotCheckProcess.java | 206 +++++++-----
.../snapshot/SnapshotCheckProcessRequest.java | 24 +-
.../snapshot/SnapshotCheckResponse.java | 74 +++++
.../persistence/snapshot/SnapshotChecker.java | 65 +++-
.../persistence/snapshot/SnapshotHandler.java | 3 +-
.../snapshot/SnapshotHandlerContext.java | 25 +-
.../snapshot/SnapshotHandlerRestoreTask.java | 73 -----
.../snapshot/SnapshotHandlerResult.java | 34 +-
.../persistence/snapshot/SnapshotMetadata.java | 2 +
.../snapshot/SnapshotMetadataResponse.java | 67 ++++
.../snapshot/SnapshotOperationEndRequest.java | 33 +-
.../snapshot/SnapshotOperationRequest.java | 41 ++-
.../snapshot/SnapshotOperationResponse.java} | 39 +--
.../SnapshotPartitionsQuickVerifyHandler.java | 12 +-
.../snapshot/SnapshotPartitionsVerifyHandler.java | 43 ++-
.../SnapshotPartitionsVerifyHandlerResponse.java | 69 ++++
.../snapshot/SnapshotRestoreOperationResponse.java | 93 ++++++
.../snapshot/SnapshotRestoreProcess.java | 137 ++++----
.../snapshot/SnapshotRestoreStartRequest.java} | 44 ++-
.../snapshot/SnapshotStartDiscoveryMessage.java} | 55 ++--
.../cache/query/GridCacheQueryRequest.java | 9 +-
.../continuous/CacheContinuousQueryEntry.java | 76 +++--
.../cache/transactions/TxEntryValueHolder.java | 20 +-
.../cache/version/GridCacheRawVersionedEntry.java | 210 +-----------
.../processors/datastreamer/DataStreamerEntry.java | 65 +---
.../dr/IgniteDrDataStreamerCacheUpdater.java | 2 -
.../internal/processors/job/GridJobProcessor.java | 2 +-
.../internal/processors/job/GridJobWorker.java | 75 ++---
.../marshaller/MappingAcceptedMessage.java | 23 +-
.../marshaller/MappingProposedMessage.java | 37 ++-
.../marshaller/MarshallerMappingItem.java | 24 +-
.../PerformanceStatisticsProcessor.java | 4 +-
.../platform/client/ClientConnectionContext.java | 5 +-
.../platform/client/ClientResourceRegistry.java | 31 +-
.../cache/ClientCacheQueryContinuousHandle.java | 9 +-
.../internal/processors/query/QueryField.java | 74 ++++-
.../message/SchemaAbstractDiscoveryMessage.java | 44 +--
.../SchemaAbstractAlterTableOperation.java | 39 ---
.../schema/operation/SchemaAbstractOperation.java | 18 +-
.../operation/SchemaAddQueryEntityOperation.java | 42 ++-
.../SchemaAlterTableAddColumnOperation.java | 23 +-
.../SchemaAlterTableDropColumnOperation.java | 23 +-
.../operation/SchemaIndexAbstractOperation.java | 5 +-
.../operation/SchemaIndexCreateOperation.java | 45 ++-
.../schema/operation/SchemaIndexDropOperation.java | 15 +-
.../processors/service/IgniteServiceProcessor.java | 10 -
.../util/distributed/DistributedProcess.java | 4 +-
.../internal/util/distributed/FullMessage.java | 46 ++-
.../internal/util/distributed/InitMessage.java | 34 +-
.../util/distributed/SingleNodeMessage.java | 121 ++-----
.../communication/MarshallableMessage.java | 9 +-
.../tcp/internal/CommunicationWorker.java | 2 +
.../tcp/internal/ConnectionClientPool.java | 361 ++++++++++-----------
.../ignite/spi/deployment/DeploymentListener.java | 4 +
.../ignite/spi/deployment/DeploymentResource.java | 4 +
.../spi/deployment/DeploymentResourceAdapter.java | 4 +
.../ignite/spi/deployment/DeploymentSpi.java | 4 +
.../spi/deployment/local/LocalDeploymentSpi.java | 3 +
.../deployment/local/LocalDeploymentSpiMBean.java | 4 +
.../ignite/spi/discovery/tcp/ClientImpl.java | 2 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 25 +-
.../TcpDiscoveryAbstractTraceableMessage.java | 31 +-
.../TcpDiscoveryClientReconnectMessage.java | 52 +--
.../messages/TcpDiscoveryCollectionMessage.java | 143 ++++++++
.../messages/TcpDiscoveryCustomEventMessage.java | 18 +-
.../messages/TcpDiscoveryJoinRequestMessage.java | 27 +-
.../TcpDiscoveryNodeAddFinishedMessage.java | 30 +-
.../tcp/messages/TcpDiscoveryNodeAddedMessage.java | 112 +++++--
.../messages/TcpDiscoveryNodeFailedMessage.java | 3 +-
.../tcp/messages/TcpDiscoveryNodeLeftMessage.java | 3 +-
.../main/resources/META-INF/classnames.properties | 4 -
...dCachePartitionExchangeManagerWarningsTest.java | 76 ++++-
.../binary/GridBinaryAffinityKeySelfTest.java | 6 +
.../direct/DirectMarshallingMessagesTest.java | 106 ------
.../encryption/CacheGroupKeyChangeTest.java | 4 +-
.../CacheEntryPredicateAdapterMessageTest.java | 59 +++-
.../communication/CompressedMessageTest.java | 4 +-
.../communication/ErrorMessageSelfTest.java | 22 +-
...iteIoCommunicationMessageSerializationTest.java | 4 +-
.../communication/IndexKeyTypeMessageTest.java | 145 +++++++--
...loymentRequestOfUnknownClassProcessingTest.java | 14 +-
.../IgniteDiscoveryMessageSerializationTest.java | 5 +-
.../wal/record/WALRecordSerializationTest.java | 38 ++-
.../cache/ClientSlowDiscoveryAbstractTest.java | 2 +-
.../ClientSlowDiscoveryTransactionRemapTest.java | 30 +-
...teMarshallerCacheClientRequestsMappingTest.java | 6 +-
.../IgniteDataStorageMetricsSelfTest.java | 81 ++++-
.../db/IgniteSequentialNodeCrashRecoveryTest.java | 2 +-
.../snapshot/AbstractSnapshotSelfTest.java | 18 +-
.../snapshot/IgniteClusterSnapshotCheckTest.java | 324 +++++++++++++++++-
.../snapshot/IgniteClusterSnapshotHandlerTest.java | 66 ++--
.../snapshot/IgniteSnapshotManagerSelfTest.java | 2 +-
.../snapshot/IncrementalSnapshotTest.java | 3 +-
.../IncrementalSnapshotJoiningClientTest.java | 2 +-
...niteCacheContinuousQueryImmutableEntryTest.java | 4 +-
.../query/schema/IndexWithSameNameTestBase.java | 2 +-
.../rest/RestProcessorInitializationTest.java | 32 +-
.../IgniteServiceDeployOnJoinedNodeTest.java | 94 ++++++
.../IgniteServiceDeploymentFailureTest.java | 31 +-
.../DistributedProcessClientAwaitTest.java | 34 +-
.../DistributedProcessCoordinatorLeftTest.java | 20 +-
.../DistributedProcessErrorHandlingTest.java | 17 +-
.../util/distributed/MessagesPluginProvider.java | 64 ++++
.../util/distributed/TestIntegerMessage.java} | 40 ++-
.../util/distributed/TestUuidMessage.java} | 32 +-
.../ignite/p2p/GridP2PHotRedeploymentSelfTest.java | 16 -
.../GridAbstractCommunicationSelfTest.java | 4 +-
.../CommunicationConnectionPoolMetricsTest.java | 43 ++-
...pCommunicationSpiConcurrentConnectSelfTest.java | 4 +-
.../tcp/GridTcpCommunicationSpiConfigSelfTest.java | 4 +-
...idTcpCommunicationSpiMultithreadedSelfTest.java | 3 +-
...GridTcpCommunicationSpiRecoveryAckSelfTest.java | 4 +-
.../GridTcpCommunicationSpiRecoverySelfTest.java | 4 +-
...TcpCommunicationRecoveryAckClosureSelfTest.java | 4 +-
...cpCommunicationSpiHalfOpenedConnectionTest.java | 24 +-
.../spi/discovery/tcp/BlockTcpDiscoverySpi.java | 2 +-
.../spi/discovery/tcp/TcpDiscoverySelfTest.java | 2 +-
.../ignite/testframework/GridSpiTestContext.java | 4 +-
.../testsuites/IgniteMarshallerSelfTestSuite.java | 2 -
.../testsuites/IgniteServiceGridTestSuite.java | 2 +
.../IgniteSpiCommunicationSelfTestSuite.java | 2 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 6 +-
.../resources/codegen/TestMarshallableMessage.java | 24 +-
...tMarshallableMessageMarshallableSerializer.java | 18 +-
.../src/test/resources/codegen/TestMessage.java | 4 +-
.../resources/codegen/TestMessageSerializer.java | 4 +-
.../thin-client/src/impl/notification_handler.h | 16 +-
.../spi/deployment/uri/UriDeploymentSpi.java | 3 +
.../spi/deployment/uri/UriDeploymentSpiMBean.java | 4 +
.../apache/ignite/cache/websession/WebSession.java | 30 +-
.../ignite/cache/websession/WebSessionV2.java | 31 +-
.../zk/internal/DiscoveryMessageParser.java | 2 +-
parent/pom.xml | 7 +-
parent/rat-config.xml | 9 +-
207 files changed, 4302 insertions(+), 2889 deletions(-)
create mode 100644
modules/calcite/src/test/java/org/apache/ignite/internal/processors/query/calcite/integration/PseudoColumnProviderWithNodeRestartTest.java
copy
modules/{slf4j/src/test/java/org/apache/ignite/testsuites/IgniteSlf4jTestSuite.java
=>
calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite2.java}
(85%)
copy
modules/{jcl/src/test/java/org/apache/ignite/testsuites/IgniteJclTestSuite.java
=>
calcite/src/test/java/org/apache/ignite/testsuites/IgniteCalciteTestSuite3.java}
(87%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/managers/encryption/MasterKeyChangeRequest.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/{AbstractSnapshotMessage.java
=> DataStreamerUpdatesHandlerResult.java} (60%)
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/{AbstractSnapshotMessage.java
=> SnapshotCheckHandlersNodeResponse.java} (60%)
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/{AbstractSnapshotMessage.java
=> SnapshotCheckHandlersResponse.java} (53%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCheckPartitionHashesResponse.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotCheckResponse.java
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotHandlerRestoreTask.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotMetadataResponse.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/{distributed/dht/preloader/IntLongMap.java
=> persistence/snapshot/SnapshotOperationResponse.java} (56%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotPartitionsVerifyHandlerResponse.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/snapshot/SnapshotRestoreOperationResponse.java
copy
modules/core/src/main/java/org/apache/ignite/internal/processors/{query/h2/twostep/messages/GridQueryCancelRequest.java
=> cache/persistence/snapshot/SnapshotRestoreStartRequest.java} (65%)
copy
modules/core/src/main/java/org/apache/ignite/{spi/discovery/tcp/messages/TcpDiscoveryClientAckResponse.java
=>
internal/processors/cache/persistence/snapshot/SnapshotStartDiscoveryMessage.java}
(54%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/processors/query/schema/operation/SchemaAbstractAlterTableOperation.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/messages/TcpDiscoveryCollectionMessage.java
delete mode 100644
modules/core/src/test/java/org/apache/ignite/internal/direct/DirectMarshallingMessagesTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/processors/service/IgniteServiceDeployOnJoinedNodeTest.java
rename modules/core/src/test/java/org/apache/ignite/internal/util/{ =>
distributed}/DistributedProcessClientAwaitTest.java (85%)
rename modules/core/src/test/java/org/apache/ignite/internal/util/{ =>
distributed}/DistributedProcessCoordinatorLeftTest.java (87%)
rename modules/core/src/test/java/org/apache/ignite/internal/util/{ =>
distributed}/DistributedProcessErrorHandlingTest.java (93%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/distributed/MessagesPluginProvider.java
copy modules/core/src/test/{resources/codegen/WrongOrderEnumeration.java =>
java/org/apache/ignite/internal/util/distributed/TestIntegerMessage.java} (65%)
copy
modules/{calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/QueryCloseMessage.java
=>
core/src/test/java/org/apache/ignite/internal/util/distributed/TestUuidMessage.java}
(65%)
rename modules/core/src/test/java/org/apache/ignite/spi/communication/tcp/{ =>
internal}/TcpCommunicationSpiHalfOpenedConnectionTest.java (88%)
