This is an automated email from the ASF dual-hosted git repository.
timoninmaxim pushed a change to branch IGNITE-22662__snapshot_refactoring
in repository https://gitbox.apache.org/repos/asf/ignite.git
from 8ef9bcf8ee1 IGNITE-22662 : Snapshot check as distributed process
(#11391)
add f06c1480758 IGNITE-22319 Fixed node crashing if a snapshot restore
cancelled due to network issues (#11361)
add 47a09b3ab7c IGNITE-22875 Added limitations for colocated joins (#11459)
add 9000d2e07ef IGNITE-22864 Added flag to ignore existing caches to the
cache create command (#11460)
add 3b8e51345f7 IGNITE-22790 Initial cleanup of Grid*Request and
Grid*Response classes (#11461)
add e5a199fd64a IGNITE-22952 Fix lambda classname parsing in deployment
for Java 21+ (#11466)
add eae99b2509a IGNITE-14726 Fix [Log4j2] Omitted start character [ in
default log pattern (#11468)
add 68533e0d984 IGNITE-22590 SQL Calcite: Fix rehashing of inputs
containing null values - Fixes #11410.
add 984d9ae8668 IGNITE-22844 Fixed permissions required by control.sh
--consistency repair command (#11456)
add 1d9312af9a5 IGNITE-22962 Added conflict resolver metrics (#11469)
add 7f35ec7e96e IGNITE-22862 Add address information to
ClientConnectionException stacktrace - Fixes #11462.
add 6864b43cd02 IGNITE-22967 SQL Calcite: Fix lost limit/offset on
planning - Fixes #11471.
add feab5132fcd IGNITE-22992 SQL Calcite: Refactor
BaseQueryContext.Builder#frameworkConfig - Fixes #11479.
add edb32fa046a IGNITE-22994 Refactor subscription to
activation/deactivation events for internal components - Fixes #11480.
add 6fb58f28138 IGNITE-22917 Remove GridDhtLockRequest#nearKeys (#11474)
add 818118e2795 IGNITE-22998 Fix LongDestroyDurableBackgroundTaskTest
(#11489)
add 12cb12c3a4d IGNITE-22767 Remove MarshallingContext (#11442)
add add61eb5887 IGNITE-22964 Java thin: fix client init hang on
unreachable discovered address (#11486)
new dd338c844f7 Merge branch 'master' into
IGNITE-22662__snapshot_refactoring
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/_docs/SQL/distributed-joins.adoc | 21 +++
.../change-data-capture-extensions.adoc | 13 --
docs/_docs/monitoring-metrics/new-metrics.adoc | 3 +
docs/_docs/tools/control-script.adoc | 8 +-
.../query/calcite/CalciteQueryProcessor.java | 1 +
.../processors/query/calcite/RootQuery.java | 13 +-
.../query/calcite/exec/ExecutionServiceImpl.java | 8 +-
.../query/calcite/exec/LogicalRelImplementor.java | 21 +++
.../query/calcite/message/ErrorMessage.java | 10 +-
.../query/calcite/message/GenericValueMessage.java | 13 +-
.../query/calcite/message/MarshalableMessage.java | 9 +-
.../query/calcite/message/MarshallingContext.java | 58 -------
.../query/calcite/message/MessageServiceImpl.java | 61 ++------
.../query/calcite/message/QueryBatchMessage.java | 5 +-
.../query/calcite/message/QueryStartRequest.java | 10 +-
.../query/calcite/message/QueryStartResponse.java | 10 +-
.../query/calcite/message/ValueMessage.java | 5 +-
.../query/calcite/metadata/ColocationGroup.java | 6 +-
.../calcite/metadata/FragmentDescription.java | 6 +-
.../query/calcite/metadata/FragmentMapping.java | 6 +-
.../query/calcite/prepare/BaseQueryContext.java | 29 +++-
.../processors/query/calcite/rel/IgniteLimit.java | 14 +-
.../processors/query/calcite/rel/IgniteSort.java | 10 +-
.../calcite/exec/LogicalRelImplementorTest.java | 8 +-
.../calcite/exec/rel/AbstractExecutionTest.java | 2 +
.../integration/JoinRehashIntegrationTest.java | 60 +++++--
.../integration/LimitOffsetIntegrationTest.java | 10 ++
.../query/calcite/planner/AbstractPlannerTest.java | 20 +--
.../calcite/planner/LimitOffsetPlannerTest.java | 12 ++
.../query/calcite/planner/PlannerTest.java | 134 ++++------------
.../ignite/common/NodeSslConnectionMetricTest.java | 24 ++-
.../SecurityCommandHandlerPermissionsTest.java | 8 +-
.../util/GridCommandHandlerClusterByClassTest.java | 9 +-
.../util/GridCommandHandlerConsistencyTest.java | 98 +++++++++---
...> cache-create-correct-skip-existing-check.xml} | 6 +
.../sorted/inline/InlineTreeFilterClosure.java | 2 +-
.../internal/client/thin/ReliableChannel.java | 29 +++-
.../internal/client/thin/TcpClientChannel.java | 17 +-
.../GridNioClientConnectionMultiplexer.java | 2 +-
.../cluster/DistributedBaselineConfiguration.java | 16 +-
.../management/cache/CacheCreateCommand.java | 7 +
.../management/cache/CacheCreateCommandArg.java | 16 ++
.../internal/management/cache/CacheCreateTask.java | 12 +-
.../consistency/ConsistencyRepairTask.java | 4 +-
.../deployment/GridDeploymentCommunication.java | 15 +-
.../managers/encryption/GridEncryptionManager.java | 2 +
.../processors/cache/CacheMetricsImpl.java | 50 +++++-
.../processors/cache/GridCacheContext.java | 10 ++
.../processors/cache/GridCacheMessage.java | 11 +-
.../internal/processors/cache/GridCacheUtils.java | 14 +-
.../distributed/GridCacheTxRecoveryRequest.java | 2 +-
.../distributed/GridCacheTxRecoveryResponse.java | 2 +-
.../distributed/GridDistributedLockRequest.java | 20 +--
.../distributed/GridDistributedLockResponse.java | 6 +-
.../GridDistributedTxFinishRequest.java | 2 +-
.../GridDistributedTxFinishResponse.java | 2 +-
.../distributed/GridDistributedTxMapping.java | 12 +-
.../GridDistributedTxPrepareRequest.java | 31 ++--
.../GridDistributedTxPrepareResponse.java | 6 +-
.../GridDistributedTxRemoteAdapter.java | 2 +-
.../distributed/GridDistributedUnlockRequest.java | 11 +-
.../cache/distributed/dht/GridDhtLockFuture.java | 3 +-
.../cache/distributed/dht/GridDhtLockRequest.java | 90 ++---------
.../cache/distributed/dht/GridDhtLockResponse.java | 17 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 43 ++----
.../distributed/dht/GridDhtTxFinishResponse.java | 8 +-
.../cache/distributed/dht/GridDhtTxMapping.java | 2 +-
.../distributed/dht/GridDhtTxPrepareRequest.java | 8 +-
.../distributed/dht/GridDhtTxPrepareResponse.java | 16 +-
.../distributed/dht/GridDhtUnlockRequest.java | 4 +-
.../dht/colocated/GridDhtColocatedCache.java | 119 +++++++-------
.../dht/colocated/GridDhtColocatedLockFuture.java | 5 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 8 +-
.../cache/distributed/near/GridNearGetRequest.java | 8 +-
.../distributed/near/GridNearGetResponse.java | 10 +-
.../cache/distributed/near/GridNearLockFuture.java | 7 +-
.../distributed/near/GridNearLockRequest.java | 24 +--
.../distributed/near/GridNearSingleGetRequest.java | 8 +-
.../near/GridNearSingleGetResponse.java | 12 +-
.../near/GridNearTransactionalCache.java | 172 +--------------------
.../distributed/near/GridNearTxFinishResponse.java | 7 +-
.../distributed/near/GridNearTxPrepareRequest.java | 2 +-
.../near/GridNearTxPrepareResponse.java | 22 ++-
.../cache/distributed/near/GridNearTxRemote.java | 94 +----------
.../snapshot/IgniteSnapshotManager.java | 94 +++++------
.../snapshot/SnapshotRestoreProcess.java | 2 +-
.../cache/transactions/IgniteTxAdapter.java | 2 +-
.../cache/transactions/IgniteTxLocalAdapter.java | 2 +-
.../cache/transactions/TxLocksRequest.java | 9 +-
.../cache/transactions/TxLocksResponse.java | 11 +-
.../cluster/GridClusterStateProcessor.java | 10 +-
.../datastructures/DataStructuresProcessor.java | 2 +
.../persistence/DistributedMetaStorageImpl.java | 3 +
.../GridInternalSubscriptionProcessor.java | 16 +-
.../processors/task/GridTaskProcessor.java | 4 +-
.../apache/ignite/internal/util/IgniteUtils.java | 8 +-
.../org/apache/ignite/client/ReliabilityTest.java | 12 +-
.../internal/client/thin/ComputeTaskTest.java | 4 +-
.../internal/client/thin/FunctionalTest.java | 3 +
.../ThinClientAbstractPartitionAwarenessTest.java | 56 ++++++-
.../thin/ThinClientEnpointsDiscoveryTest.java | 45 ++++++
...ientPartitionAwarenessUnstableTopologyTest.java | 4 +-
.../metric/CacheMetricsConflictResolverTest.java | 146 +++++++++++++++++
.../IgniteSnapshotRestoreFromRemoteTest.java | 55 +++++++
.../ignite/testsuites/IgniteCacheTestSuite13.java | 2 +
...mandHandlerClusterByClassTest_cache_help.output | 3 +-
...dlerClusterByClassWithSSLTest_cache_help.output | 3 +-
.../db/LongDestroyDurableBackgroundTaskTest.java | 4 +-
.../apache/ignite/logger/log4j2/Log4J2Logger.java | 2 +-
109 files changed, 1142 insertions(+), 1083 deletions(-)
delete mode 100644
modules/calcite/src/main/java/org/apache/ignite/internal/processors/query/calcite/message/MarshallingContext.java
copy
modules/control-utility/src/test/resources/config/cache/{cache-create-correct.xml
=> cache-create-correct-skip-existing-check.xml} (84%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/metric/CacheMetricsConflictResolverTest.java