This is an automated email from the ASF dual-hosted git repository.
mpochatkin pushed a change to branch IGNITE-26191
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 49180487c2a Fixes
add dbda22fc6af Revert "Bump io.swagger.core.v3:swagger-annotations from
2.2.34 to 2.2.35 (#6351)"
add 6597998baa4 IGNITE-26188 Fix potential memory leak in
DelayedPageReplacementTracker (#6407)
add 0ac1e575f6b IGNITE-26193 Reduce the number of TxPriority[] allocations
(#6411)
add 3c03e789b23 IGNITE-26170 Update criteria query example (#6393)
add 4db00b0b477 IGNITE-26195 Reduce the number of lambda allocations in
BinaryRowConverter (#6412)
add 5a331a01034 IGNITE-21632 Upgrade to PMD 7.0 (#6357)
add a2f79d1b985 IGNITE-25693 Reduce client connector logging level on SSL
and handhsake errors (#6415)
add 2e5f3cc39f1 IGNITE-25903 Sql. Support literals in PA metadata builder
(#6406)
add 339709ec4e8 IGNITE-26138 Sql. Partition awareness. Prepare partition
pruning metadata after planning (#6374)
add 3487e50d3e7 IGNITE-26163 Improve MT error logging (#6387)
add e4e6618c9e5 IGNITE-26031 Fix
ItConnectionErrorTest.testStopLeader/Follower (#6419)
add 4235b2880a4 IGNITE-26201 Stop persisting calculated default storage
profile size (#6422)
add c0a3e9f0a0b IGNITE-26197 Add configuration information into the
message about critical thread being blocked (#6426)
add b19d0dc0f39 IGNITE-26205 Raise maxAllowedLagMillis default to 5
seconds (#6427)
add 20a5873c8d3 IGNITE-26198 Sql. Added SQL property to optionally
restrict query execution with multiple statements (#6420)
add 0f57457c220 IGNITE-25953 Report to log TimeoutExceptions during safe
time sync (#6389)
add 32a6c467699 IGNITE-26196 Make node staleness status volatile (#6424)
add a5e31626daf Merge branch 'main' into IGNITE-26191
No new revisions were added by this update.
Summary of changes:
check-rules/pmd-rules.xml | 3 +-
.../administrators-guide/config/node-config.adoc | 12 +-
gradle/libs.versions.toml | 4 +-
.../exceptions/DataStreamerExceptionHandler.java | 24 ++-
...cordAndTableSchemaMismatchExceptionHandler.java | 37 ++--
.../tests/clusters/FullSampleCluster.java | 6 +-
.../tests/containers/Ignite2ClusterContainer.java | 3 +
.../ignite/migrationtools/sql/SqlDdlGenerator.java | 2 +
.../types/converters/IdentityConverter.java | 2 +-
.../sql/sql/SqlDdlGeneratorTest.java | 48 +++--
.../persistence/Ignite2PersistentCacheTools.java | 22 +++
.../persistence/MigrationKernalContext.java | 2 +-
.../exceptions/MigrateCacheException.java | 56 ++++++
.../utils/pubsub/RateLimiterProcessorTest.java | 5 +-
.../java/org/apache/ignite/table/TupleImpl.java | 3 +-
.../org/apache/ignite/table/criteria/Criteria.java | 4 +-
.../internal/binarytuple/BinaryTupleParser.java | 2 +-
.../internal/catalog/storage/UpdateLogImpl.java | 4 +-
.../catalog/storage/UpdateLogImplTest.java | 2 +-
.../call/recovery/states/PartitionStatesCall.java | 8 +-
.../cli/core/decorator/DecoratorRegistry.java | 2 +
.../repl/completer/DynamicCompletionInsider.java | 7 +-
.../client/proto/ClientMessageUnpacker.java | 2 +-
.../client/proto/pojo/PojoConverterTest.java | 2 +
.../handler/ClientInboundMessageHandler.java | 15 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 3 +-
.../requests/sql/ClientSqlExecuteRequest.java | 3 +-
.../apache/ignite/internal/client/ClientUtils.java | 4 +-
.../ignite/client/AbstractClientTableTest.java | 4 +-
.../apache/ignite/client/AbstractClientTest.java | 3 +
.../ignite/client/fakes/FakeColumnMetadata.java | 10 +-
.../configuration/ConfigurationListenerHolder.java | 3 +
.../configuration/util/ConfigurationUtil.java | 2 +-
.../notifications/ConfigurationListenerTest.java | 12 +-
.../tree/TraversableTreeNodeTest.java | 14 +-
.../extension/ExtendedTraversableTreeNodeTest.java | 8 +-
.../PolymorphicTraversableTreeNodeTest.java | 12 +-
.../internal/lang/IgniteExceptionMapper.java | 4 +-
.../internal/lang/IgniteStringFormatter.java | 5 +-
.../ignite/internal/sql/SyncResultSetAdapter.java | 2 +-
.../ignite/internal/thread/IgniteThread.java | 2 +-
.../internal/tostring/IgniteToStringBuilder.java | 4 +-
.../ignite/internal/util/ExceptionUtils.java | 2 +-
.../apache/ignite/internal/util/GridUnsafe.java | 46 +++--
.../org/apache/ignite/internal/util/HashUtils.java | 9 +
.../apache/ignite/internal/util/VarIntUtils.java | 9 +
.../internal/util/io/IgniteUnsafeDataInput.java | 2 +-
.../tostring/IgniteToStringBuilderSelfTest.java | 15 +-
.../ignite/internal/util/CollectionUtilsTest.java | 2 +
.../util/IgniteConcurrentMultiPairQueueTest.java | 8 +-
.../util/PendingComparableValuesTrackerTest.java | 10 +-
.../ignite/internal/util/io/IgniteTestIoUtils.java | 7 +-
...niteDistributionZoneManagerNodeRestartTest.java | 4 +-
.../eventlog/ser/JacksonBasedJsonSerializer.java | 11 +-
.../internal/network/file/messages/FileHeader.java | 2 +-
.../ignite/internal/jdbc/JdbcConnection.java | 12 +-
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcStatement.java | 8 +-
.../org/apache/ignite/jdbc/IgniteJdbcDriver.java | 2 +-
.../internal/marshaller/FieldAccessorTest.java | 2 +-
.../server/persistence/RocksDbKeyValueStorage.java | 4 +-
.../ignite/internal/metrics/HitRateMetric.java | 3 +
.../internal/network/MapChannelTypeRegistry.java | 2 +
modules/network/build.gradle | 1 +
.../node/ItNodeStalenessAndRestartTest.java | 77 ++++++++
.../network/MapStripedExecutorByChannelTypeId.java | 2 +
.../stream/DirectByteBufferStreamImplV1.java | 9 +-
.../network/recovery/InMemoryStaleIds.java | 3 +-
.../internal/network/recovery/VaultStaleIds.java | 107 ----------
.../network/serialization/BuiltInType.java | 4 +-
.../network/serialization/SerializationType.java | 2 +-
.../serialization/marshal/LittleEndianBits.java | 2 +
.../network/DefaultMessagingServiceTest.java | 2 +-
.../network/SerializationMicroBenchmark.java | 7 +-
.../ignite/internal/network/UosProfilerTarget.java | 2 +-
.../network/recovery/InMemoryStaleIdsTest.java} | 36 ++--
.../network/recovery/VaultStaleIdsTest.java | 124 ------------
...shallerWithSerializableOverrideStreamsTest.java | 6 +-
...ltUserObjectMarshallerWithSerializableTest.java | 2 +
.../ignite/internal/pagememory/io/DataPageIo.java | 2 +-
.../replacement/DelayedPageReplacementTracker.java | 20 +-
.../persistence/store/FilePageStoreTest.java | 4 +-
.../PartitionCommandsMarshallerImpl.java | 2 +-
.../network/replication/RequestType.java | 3 -
.../ignite/internal/raft/RaftGroupServiceImpl.java | 4 +-
.../server/impl/RaftServiceEventInterceptor.java | 2 +-
.../raft/jraft/core/ReplicatorGroupImpl.java | 9 +-
.../ignite/disruptor/StripedDisruptorTest.java | 2 +
.../ignite/internal/replicator/ReplicaManager.java | 43 +++-
.../internal/benchmark/BulkLoadBenchmark.java | 28 ++-
.../ignite/internal/benchmark/SelectBenchmark.java | 6 +-
.../benchmark/SqlMultiStatementBenchmark.java | 6 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../runner/app/client/ItThinClientSqlTest.java | 59 ++++++
.../storageprofile/ItStorageProfilesTest.java | 102 ----------
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
.../testframework/TestIgnitionManager.java | 5 +-
.../ignite/internal/schema/BinaryRowConverter.java | 21 +-
.../ignite/internal/util/ColocationUtils.java | 33 ++++
.../RecordMarshallerValidationsTest.java | 2 +
.../org/apache/ignite/data/repository/Person.java | 7 +-
.../sql/engine/BaseSqlMultiStatementTest.java | 4 +-
.../sql/engine/ItSqlMultiStatementTest.java | 26 +++
.../sql/group1/explain/mapping.test | 42 ++--
.../ignite/internal/sql/api/IgniteSqlImpl.java | 6 +-
.../ignite/internal/sql/engine/SqlProperties.java | 13 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 3 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 4 +-
.../sql/engine/exec/exp/RexExecutorImpl.java | 13 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../sql/engine/exec/fsm/MultiStatementHandler.java | 3 +
.../sql/engine/exec/fsm/ValidationHelper.java | 18 +-
.../sql/engine/exec/mapping/ColocationGroup.java | 22 +++
.../sql/engine/exec/mapping/FragmentPrinter.java | 51 ++++-
.../sql/engine/exec/mapping/MappedFragment.java | 22 ++-
.../engine/exec/mapping/MappingServiceImpl.java | 17 +-
.../sql/engine/exec/mapping/QuerySplitter.java | 16 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 2 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 4 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 2 +
.../sql/engine/exec/rel/MergeJoinNode.java | 4 +-
.../sql/engine/externalize/RelJsonReader.java | 2 +-
.../internal/sql/engine/prepare/DdlPlan.java | 13 ++
.../internal/sql/engine/prepare/ExplainPlan.java | 13 ++
.../sql/engine/prepare/IgniteAliasNamespace.java | 4 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 19 +-
.../sql/engine/prepare/KeyValueModifyPlan.java | 19 +-
.../internal/sql/engine/prepare/KillPlan.java | 13 ++
.../internal/sql/engine/prepare/MultiStepPlan.java | 29 ++-
.../sql/engine/prepare/PrepareServiceImpl.java | 71 +++++--
.../internal/sql/engine/prepare/QueryPlan.java | 11 ++
.../sql/engine/prepare/SelectCountPlan.java | 11 ++
.../PartitionAwarenessMetadataExtractor.java | 57 +++++-
.../engine/prepare/pruning/PartitionPruner.java | 3 +-
.../prepare/pruning/PartitionPrunerImpl.java | 28 ++-
.../prepare/pruning/PartitionPruningMetadata.java | 25 +++
.../prepare/pruning/PartitionPruningPredicate.java | 6 +-
.../engine/rel/explain/RelTreeToTextWriter.java | 11 +-
.../sql/engine/sql/IgniteAbstractSqlAlterZone.java | 3 +-
.../ignite/internal/sql/engine/util/Cloner.java | 59 ++++++
.../ignite/internal/sql/engine/util/Commons.java | 5 +-
.../internal/sql/engine/util/IgniteMath.java | 2 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 38 +++-
.../sql/engine/exec/ExecutionServiceImplTest.java | 24 +--
.../sql/engine/exec/RuntimeSortedIndexTest.java | 18 +-
.../exec/coercion/BaseTypeCheckExecutionTest.java | 2 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 19 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 19 +-
.../exec/mapping/MappingServiceImplTest.java | 2 +-
.../sql/engine/exec/mapping/MappingTestRunner.java | 18 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 2 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 2 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 2 +-
.../sql/engine/exec/rel/SingleRangeIterable.java | 2 +-
.../sql/engine/framework/DataProvider.java | 2 +-
.../sql/engine/planner/AbstractPlannerTest.java | 3 +
.../planner/AbstractTpcQueryPlannerTest.java | 4 +-
.../planner/PartitionPruningMetadataTest.java | 5 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 7 +-
.../PartitionAwarenessMetadataTest.java | 171 ++++++++++------
.../pruning/PartitionPruningPredicateSelfTest.java | 15 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 2 +-
.../internal/sql/engine/util/StatementChecker.java | 2 +-
.../src/test/resources/mapping/correlated.test | 191 +++++++++++-------
.../sql-engine/src/test/resources/mapping/dml.test | 57 ++++--
.../src/test/resources/mapping/hash_join.test | 73 ++++---
.../src/test/resources/mapping/merge_join.test | 23 ++-
.../src/test/resources/mapping/set_ops.test | 35 ++--
.../src/test/resources/mapping/table_affinity.test | 52 +++--
.../test/resources/mapping/table_functions.test | 3 +-
.../src/test/resources/mapping/table_identity.test | 84 +++++---
.../resources/mapping/table_identity_single.test | 60 ++++--
.../src/test/resources/mapping/table_single.test | 36 +++-
.../resources/mapping/test_backup_mapping.test | 160 +++++++++------
.../resources/mapping/test_partition_pruning.test | 218 ++++++++++++++++-----
.../src/test/resources/mapping/union.test | 74 ++++---
.../src/test/resources/mapping/values.test | 6 +-
.../internal/sql/engine/util/QueryCheckerImpl.java | 1 +
.../pagememory/PersistentPageMemoryDataRegion.java | 26 ++-
.../PersistentPageMemoryStorageEngine.java | 29 ---
.../pagememory/VolatilePageMemoryDataRegion.java | 40 +++-
.../VolatilePageMemoryStorageEngine.java | 44 -----
.../storage/pagememory/mv/io/BlobFragmentIo.java | 2 +-
.../PersistentPageMemoryStorageEngineTest.java | 7 -
.../VolatilePageMemoryStorageEngineTest.java | 23 ---
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 2 +
.../storage/rocksdb/RocksDbStorageEngine.java | 29 +--
.../storage/rocksdb/RocksDbStorageProfile.java | 35 +++-
.../rocksdb/index/RocksDbHashIndexStorage.java | 2 +
.../rocksdb/index/RocksDbSortedIndexStorage.java | 2 +
.../rocksdb/engine/RocksDbStorageEngineTest.java | 7 -
.../instance/SharedRocksDbInstanceTest.java | 4 +-
.../ItAbstractInternalTableScanTest.java | 5 +-
.../internal/table/distributed/PartitionSet.java | 2 +-
.../internal/table/distributed/gc/MvGcTest.java | 2 +-
.../table/type/NumericTypesSerializerTest.java | 2 +-
.../apache/ignite/internal/tx/TransactionIds.java | 2 +-
.../rocksdb/TxStateRocksDbPartitionStorage.java | 2 +
.../worker/ItCriticalWorkerMonitoringTest.java | 3 +-
.../internal/worker/CriticalWorkerWatchdog.java | 24 +--
.../CriticalWorkersConfigurationSchema.java | 6 +-
203 files changed, 2315 insertions(+), 1393 deletions(-)
create mode 100644
migration-tools/modules/migration-tools-persistence/src/main/java/org/apache/ignite/migrationtools/persistence/exceptions/MigrateCacheException.java
create mode 100644
modules/network/src/integrationTest/java/org/apache/ignite/internal/network/node/ItNodeStalenessAndRestartTest.java
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/VaultStaleIds.java
copy
modules/{storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/engine/AbstractVolatileStorageEngineTest.java
=>
network/src/test/java/org/apache/ignite/internal/network/recovery/InMemoryStaleIdsTest.java}
(52%)
delete mode 100644
modules/network/src/test/java/org/apache/ignite/internal/network/recovery/VaultStaleIdsTest.java
delete mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/storageprofile/ItStorageProfilesTest.java
