This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-24036
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 77affd77a2 Minor after review.
add 92448252a9 IGNITE-23572 Nodes that returned back after majority loss
could be returned back to stable (#4905)
add 8ace698241 IGNITE-23879 Indicate stable switch after the second phase
of resetPartitions (#4916)
add 02af2a9b8a IGNITE-23634 Make hardcoded REBALANCE_RETRY_DELAY_MS
configurable (#4951)
add fee081167d IGNITE-23467 Resolve all abandoned locks for the key at a
time (#4965)
add fa0b264448 IGNITE-24112 Retry in RaftGroupServiceImpl on a
RecipientLeftException (#4967)
add 71cd440c99 IGNITE-24113 Use separate persistent log storages per Raft
node in ItNodeTest (#4969)
add f9307af9a5 IGNITE-23927
ItDataSchemaSyncTest.checkSchemasCorrectlyRestore is flaky (#4911)
add e41ee1dd79 IGNITE-24114 Only create default storage profile if it
doesn't exist (#4970)
add ed2833fc69 IGNITE-24078 Sql. Fixed handling of DDL/KILL statements
using jdbc batch (#4960)
add 51b331cbbe IGNITE-23304 Remove ordering mutex from primary replica.
add 936e22f50d IGNITE-24019 Extend SQL parser grammar with CREATE/DROP
SCHEMA statements (#4963)
add 2a8d29f860 IGNITE-24060 Fix scale down behaviour for HA zones (#4973)
add b357efdd7b IGNITE-24121 Use HeapLockManager with less slots in tests
(#4975)
add dcb7f1c7e4 IGNITE-24124 Fix pool starvation in
TableManager#beforeNodeStop() (#4981)
add aa654a614d IGNITE-24122 Add -Xmx1g to defaultJvmArgs (#4976)
add 4d2c8971f1 IGNITE-24108 Fix client JMX export, fix MBean package
(#4962)
add ecffc52434 IGNITE-21558 Sql. Remove ExecutionContext dependency from
ExpressionFactory (#4959)
add 6b9d2460f2 IGNITE-23893 Java thin: improve javadocs (#4982)
add 86cc298423 IGNITE-23305 Get rid of client HybridTimestampTracker
(#4929)
add 51cb224311 IGNITE-24128 Remove casts to RestartProofIgnite (#4983)
add 9dc124a980 Merge branch 'main' into ignite-24036
No new revisions were added by this update.
Summary of changes:
build.gradle | 3 +-
buildscripts/java-junit5.gradle | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 -
.../apache/ignite/client/handler/TestServer.java | 4 +-
.../ignite/client/handler/ClientHandlerModule.java | 15 +-
.../handler/ClientInboundMessageHandler.java | 138 ++-
.../client/handler/JdbcQueryEventHandlerImpl.java | 98 +-
.../jdbc/ClientJdbcExecuteBatchRequest.java | 12 +-
.../requests/jdbc/ClientJdbcExecuteRequest.java | 12 +-
.../requests/jdbc/ClientJdbcFinishTxRequest.java | 19 +-
.../jdbc/ClientJdbcPreparedStmntBatchRequest.java | 12 +-
.../requests/sql/ClientSqlCursorCloseRequest.java | 12 +-
.../sql/ClientSqlCursorNextPageRequest.java | 6 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 12 +-
.../requests/sql/ClientSqlExecuteRequest.java | 43 +-
.../sql/ClientSqlExecuteScriptRequest.java | 9 +-
.../handler/requests/table/ClientTableCommon.java | 38 +-
.../table/ClientTupleContainsAllKeysRequest.java | 10 +-
.../table/ClientTupleContainsKeyRequest.java | 18 +-
.../table/ClientTupleDeleteAllExactRequest.java | 16 +-
.../table/ClientTupleDeleteAllRequest.java | 9 +-
.../table/ClientTupleDeleteExactRequest.java | 9 +-
.../requests/table/ClientTupleDeleteRequest.java | 9 +-
.../requests/table/ClientTupleGetAllRequest.java | 9 +-
.../table/ClientTupleGetAndDeleteRequest.java | 9 +-
.../table/ClientTupleGetAndReplaceRequest.java | 9 +-
.../table/ClientTupleGetAndUpsertRequest.java | 9 +-
.../requests/table/ClientTupleGetRequest.java | 14 +-
.../table/ClientTupleInsertAllRequest.java | 9 +-
.../requests/table/ClientTupleInsertRequest.java | 9 +-
.../table/ClientTupleReplaceExactRequest.java | 9 +-
.../requests/table/ClientTupleReplaceRequest.java | 9 +-
.../table/ClientTupleUpsertAllRequest.java | 16 +-
.../requests/table/ClientTupleUpsertRequest.java | 10 +-
.../requests/tx/ClientTransactionBeginRequest.java | 24 +-
.../tx/ClientTransactionCommitRequest.java | 24 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 30 +-
.../apache/ignite/client/ClientOperationType.java | 2 +
.../org/apache/ignite/client/IgniteClient.java | 12 +
.../ignite/client/IgniteClientAddressFinder.java | 14 +-
.../ignite/client/IgniteClientConfiguration.java | 1 +
.../java/org/apache/ignite/client/RetryPolicy.java | 8 +-
.../ignite/internal/client/TcpIgniteClient.java | 4 +-
.../apache/ignite/client/ClientMetricsTest.java | 38 +
.../client/ObservableTimestampPropagationTest.java | 41 +-
.../ignite/client/TestClientHandlerModule.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 3 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 11 +-
.../ignite/client/fakes/FakeIgniteTables.java | 2 +-
...stemDistributedConfigurationPropertyHolder.java | 112 ++
...istributedConfigurationPropertyHolderTest.java} | 80 +-
.../apache/ignite/internal/hlc/HybridClock.java | 2 +-
.../ignite/internal/hlc/HybridClockImpl.java | 46 +-
.../internal/lang/SafeTimeReorderException.java | 48 -
.../apache/ignite/internal/util/IgniteUtils.java | 2 +-
.../util/PendingComparableValuesTracker.java | 10 +-
.../internal/util/SafeTimeValuesTracker.java | 55 +
.../apache/ignite/internal/TestHybridClock.java | 2 +-
.../distributionzones/DistributionZoneManager.java | 39 +-
.../distributionzones/DistributionZonesUtil.java | 20 +
.../DistributionZonesConfigurationModule.java | 6 +-
...ributionZonesHighAvailabilityConfiguration.java | 103 --
.../rebalance/DistributionZoneRebalanceEngine.java | 9 +-
.../DistributionZoneRebalanceEngineV2.java | 21 +-
.../RebalanceRaftGroupEventsListener.java | 25 +-
.../distributionzones/rebalance/RebalanceUtil.java | 52 +-
.../ZoneRebalanceRaftGroupEventsListener.java | 25 +-
.../rebalance/ZoneRebalanceUtil.java | 46 +-
.../BaseDistributionZoneManagerTest.java | 4 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 2 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 5 +-
.../DistributionZonesTestUtil.java | 33 +
.../ignite/internal/index/IndexManagerTest.java | 4 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 94 +-
.../command/MetaStorageWriteCommand.java | 1 +
.../direct/stream/DirectByteBufferStream.java | 8 +
.../stream/DirectByteBufferStreamImplV1.java | 74 ++
.../partitiondistribution/Assignments.java | 49 +-
.../AssignmentsSerializer.java | 4 +-
.../AssignmentsSerializerTest.java | 44 +-
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItReplicaLifecycleTest.java | 16 +-
.../PartitionReplicaLifecycleManager.java | 24 +-
.../marshaller/PartitionCommandsMarshaller.java | 8 +
.../PartitionCommandsMarshallerImpl.java | 37 +-
.../ThreadLocalPartitionCommandsMarshaller.java | 5 +
.../PlacementDriverNodesOperabilityTest.java | 8 +-
modules/platforms/cpp/ignite/common/error_codes.h | 1 -
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 -
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 -
.../apache/ignite/internal/raft/Marshaller.java | 9 +
.../apache/ignite/internal/raft/WriteCommand.java | 18 +
.../internal/raft/service/CommandClosure.java | 8 +
.../raft/service/WriteCommandClosure.java} | 9 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 21 +-
.../jraft/core/PersistentLogStorageFactories.java | 58 +
.../apache/ignite/raft/jraft/core/TestCluster.java | 13 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 15 +-
.../internal/raft/server/RaftGroupOptions.java | 25 +
.../internal/raft/server/impl/JraftServerImpl.java | 4 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 43 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 1 +
.../apache/ignite/raft/jraft/error/RaftError.java | 7 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 4 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 73 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 13 +
.../ignite/raft/jraft/core/ReplicatorTest.java | 7 +-
.../raft/jraft/rpc/WriteActionRequestTest.java | 6 +
.../impl/core/BaseNodeRequestProcessorTest.java | 2 +-
.../impl/core/TimeoutNowRequestProcessorTest.java | 1 +
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../replicator/CommandApplicationResult.java | 11 +-
.../ignite/internal/replicator/ReplicaManager.java | 15 +-
.../command/SafeTimePropagatingCommand.java | 16 +-
.../message/ReplicaSafeTimeSyncRequest.java | 3 -
.../internal/benchmark/UpsertKvBenchmark.java | 11 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 24 +-
.../runner/app/ItIgniteNodeRestartTest.java | 16 +-
.../runner/app/PlatformTestNodeRunner.java | 2 +
.../ItDefaultStorageProfileTest.java | 59 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 17 +-
.../internal/sql/engine/ItAggregatesTest.java | 8 +
modules/sql-engine/src/main/codegen/config.fmpp | 9 +-
.../src/main/codegen/includes/parserImpls.ftl | 40 +
.../internal/sql/engine/SqlQueryProcessor.java | 8 +
.../sql/engine/exec/DynamicPartitionProvider.java | 2 +-
.../internal/sql/engine/exec/ExecutionContext.java | 10 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 9 +
.../sql/engine/exec/LogicalRelImplementor.java | 200 ++--
.../sql/engine/exec/exp/BiFieldGetter.java | 46 +
.../sql/engine/exec/exp/CommonFieldGetter.java | 61 +
.../sql/engine/exec/exp/ComparatorImplementor.java | 163 +++
.../sql/engine/exec/exp/CorrelatesBuilder.java | 76 ++
.../sql/engine/exec/exp/ExpressionFactory.java | 31 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 1214 ++------------------
.../exp/{SingleScalar.java => FieldGetter.java} | 30 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 129 +++
.../exp/{BiScalar.java => NoOpFieldGetter.java} | 21 +-
.../sql/engine/exec/exp/PredicateImplementor.java | 128 +++
.../sql/engine/exec/exp/ProjectionImplementor.java | 179 +++
.../internal/sql/engine/exec/exp/RexImpTable.java | 49 -
.../sql/engine/exec/exp/RexToLixTranslator.java | 58 +-
.../engine/exec/exp/RowProviderImplementor.java | 235 ++++
.../sql/engine/exec/exp/ScalarImplementor.java | 141 +++
.../engine/exec/exp/SearchBoundsImplementor.java | 429 +++++++
.../sql/engine/exec/exp/SqlComparator.java | 45 +
.../sql/engine/exec/exp/SqlJoinPredicate.java | 46 +
.../exp/{SingleScalar.java => SqlPredicate.java} | 23 +-
.../exec/exp/{BiScalar.java => SqlProjection.java} | 20 +-
.../exp/{SingleScalar.java => SqlRowProvider.java} | 15 +-
.../exec/exp/{BiScalar.java => SqlScalar.java} | 23 +-
.../sql/engine/exec/exp/ValuesImplementor.java | 72 ++
.../engine/exec/exp/agg/AccumulatorsFactory.java | 72 +-
.../exec/exp/func/TableFunctionRegistryImpl.java | 15 +-
.../sql/engine/exec/fsm/ValidationHelper.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 6 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 8 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 17 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 6 +-
.../sql/engine/prepare/SelectCountPlan.java | 5 +-
.../prepare/pruning/PartitionPruningPredicate.java | 5 +-
.../sql/engine/sql/IgniteSqlCreateSchema.java | 102 ++
.../sql/engine/sql/IgniteSqlDropSchema.java | 120 ++
.../IgniteSqlDropSchemaBehavior.java} | 18 +-
.../ignite/internal/sql/engine/util/Commons.java | 24 +-
.../internal/sql/engine/util/IgniteMethod.java | 8 -
.../ignite/internal/sql/engine/util/RexUtils.java | 107 ++
.../exec/ExecutableTableRegistrySelfTest.java | 2 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 5 +
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +
.../engine/exec/exp/ExpressionFactoryImplTest.java | 168 ++-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +
.../engine/exec/rel/AbstractJoinExecutionTest.java | 10 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 6 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 5 +-
.../exec/rel/HashAggregateExecutionTest.java | 10 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 7 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 18 +-
.../exec/rel/SortAggregateExecutionTest.java | 29 +-
.../exec/rel/TableScanNodeExecutionTest.java | 4 +-
.../sql/engine/framework/ExplicitTxContext.java | 2 +-
.../sql/engine/framework/ImplicitTxContext.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 4 +
.../internal/sql/engine/framework/TestNode.java | 6 +
.../pruning/PartitionPruningPredicateSelfTest.java | 2 +-
.../sql/engine/sql/SqlSchemaDdlParserTest.java | 139 +++
.../internal/sql/engine/util/QueryCheckerTest.java | 4 +-
.../engine/ThreadAssertingMvTableStorage.java | 8 +-
...emoryStorageEngineLocalConfigurationModule.java | 13 +-
modules/table/build.gradle | 1 +
.../ItInternalTableReadOnlyScanTest.java | 2 +-
.../ItInternalTableReadWriteScanTest.java | 2 +-
.../apache/ignite/distributed/ItLockTableTest.java | 2 +-
.../ItTxObservableTimePropagationTest.java | 100 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 2 +-
.../ReplicasSafeTimePropagationTest.java | 147 +--
.../ItDisasterRecoveryReconfigurationTest.java | 172 ++-
.../disaster/ItDisasterRecoverySystemViewTest.java | 3 +-
.../rebalance/ItRebalanceDistributedTest.java | 103 +-
.../ignite/internal/table/ItColocationTest.java | 4 +-
.../internal/table/ItTransactionRecoveryTest.java | 63 +-
...bstractHighAvailablePartitionsRecoveryTest.java | 2 +-
.../ItHighAvailablePartitionsRecoveryTest.java | 129 ++-
.../internal/table/distributed/TableManager.java | 89 +-
.../distributed/disaster/GroupUpdateRequest.java | 62 +-
.../table/distributed/raft/PartitionListener.java | 203 ++--
.../replicator/PartitionReplicaListener.java | 389 +++----
.../schema/CheckCatalogVersionOnActionRequest.java | 4 +-
.../schema/CheckCatalogVersionOnAppendEntries.java | 3 +-
.../schema/PartitionCommandsMarshaller.java | 8 +
.../schema/PartitionCommandsMarshallerImpl.java | 29 +-
.../ThreadLocalPartitionCommandsMarshaller.java | 11 +
.../internal/table/InteropOperationsTest.java | 2 +-
.../distributed/TableManagerRecoveryTest.java | 11 +-
.../table/distributed/TableManagerTest.java | 9 +-
.../PartitionRaftCommandsSerializationTest.java | 10 +
.../raft/PartitionCommandListenerTest.java | 88 +-
.../PartitionReplicaListenerIndexLockingTest.java | 2 +-
...itionReplicaListenerSortedIndexLockingTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 8 +-
.../CheckCatalogVersionOnActionRequestTest.java | 7 +-
.../PartitionCommandsMarshallerImplTest.java | 21 +-
.../storage/InternalTableEstimatedSizeTest.java | 2 +-
.../distributed/storage/InternalTableImplTest.java | 4 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 14 +-
.../internal/table/TxInfrastructureTest.java | 2 +-
.../table/impl/DummyInternalTableImpl.java | 18 +-
.../ignite/internal/tx/HybridTimestampTracker.java | 88 +-
.../org/apache/ignite/internal/tx/TxManager.java | 1 +
.../ignite/internal/tx/UpdateCommandResult.java | 20 +-
.../internal/tx/event/LockEventParameters.java | 19 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 36 +-
.../tx/impl/IgniteAbstractTransactionImpl.java | 14 +-
.../internal/tx/impl/IgniteTransactionsImpl.java | 51 -
.../ignite/internal/tx/impl/OrphanDetector.java | 10 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 6 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 7 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 9 +-
.../internal/tx/AbstractLockManagerEventsTest.java | 3 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 4 +-
.../internal/tx/impl/OrphanDetectorTest.java | 2 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 2 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 4 +-
243 files changed, 5906 insertions(+), 3071 deletions(-)
create mode 100644
modules/configuration-system/src/main/java/org/apache/ignite/internal/configuration/utils/SystemDistributedConfigurationPropertyHolder.java
rename
modules/{distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/configuration/DistributionZonesHighAvailabilityConfigurationTest.java
=>
configuration-system/src/test/java/org/apache/ignite/internal/configuration/utils/SystemDistributedConfigurationPropertyHolderTest.java}
(55%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/lang/SafeTimeReorderException.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/SafeTimeValuesTracker.java
delete mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/configuration/DistributionZonesHighAvailabilityConfiguration.java
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/Scalar.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/service/WriteCommandClosure.java}
(77%)
create mode 100644
modules/raft/src/integrationTest/java/org/apache/ignite/raft/jraft/core/PersistentLogStorageFactories.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/storageprofile/ItDefaultStorageProfileTest.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/BiFieldGetter.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/CommonFieldGetter.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ComparatorImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/CorrelatesBuilder.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{SingleScalar.java
=> FieldGetter.java} (52%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/JoinPredicateImplementor.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{BiScalar.java
=> NoOpFieldGetter.java} (60%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/PredicateImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ProjectionImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/RowProviderImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ScalarImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SearchBoundsImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SqlComparator.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SqlJoinPredicate.java
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{SingleScalar.java
=> SqlPredicate.java} (53%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{BiScalar.java
=> SqlProjection.java} (58%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{SingleScalar.java
=> SqlRowProvider.java} (71%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{BiScalar.java
=> SqlScalar.java} (56%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/ValuesImplementor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlCreateSchema.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlDropSchema.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{exec/exp/BiScalar.java
=> sql/IgniteSqlDropSchemaBehavior.java} (64%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/sql/SqlSchemaDdlParserTest.java
