This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-22988
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from b1b68c83da WIP
add e23e88ea6e IGNITE-23077 Fix flaky
ItIndexNodeFinishedRwTransactionsCheckerTest#testOnePhaseCommitViaKeyValue
(#4288)
add 6a77b8e5c2 IGNITE-22829 Optimize performance of count(*) (#4221)
add ccc1fbf450 IGNITE-22773 Add test on partition pruning for SQL
disjoint case (#4273)
add aa9a4c82c4 IGNITE-22170 Destroy CMG Raft group storages on init
cancellation (#4287)
add 7942a5edfb IGNITE-22949 Add for-loop support to SQL logic tests.
(#4275)
add ecbe35e102 IGNITE-20869 Got rid of using CompletableFuture#orTimeout
method on operations hot path (#4261)
add 8b705e01a1 IGNITE-22928 Fix testZoneReplicaListener (#4284)
add e1fa84c00e IGNITE-22781 Fix question during connect to a node (#4278)
add 8c6aa34998 IGNITE-20324 Implement integration tests to cover questions
in CLI (#4285)
add 2d353d9316 IGNITE-22680 Use matching assignments timestamp in zone
rebalance listener (#4282)
add f797ea24bd Merge branch 'main' into ignite-22988
add 5d441e907f WIP
No new revisions were added by this update.
Summary of changes:
modules/bytecode/build.gradle | 2 +
.../presto/bytecode/TestClassGenerator.java | 28 +-
.../ignite/internal/cli/CliIntegrationTest.java | 14 +-
.../cli/commands/ItConnectToClusterTestBase.java | 45 ++-
.../cli/commands/connect/ItConnectCommandTest.java | 48 ++-
.../connect/ItConnectNonReplCommandTest.java | 64 ++++
...tConnectWithBasicAuthenticationCommandTest.java | 116 +++++--
.../questions/ItConnectToBasicAuthClusterTest.java | 63 ----
.../commands/questions/ItConnectToClusterTest.java | 101 ++++--
.../ItConnectToSslAndAuthClusterTest.java | 189 +++++-----
.../questions/ItConnectToSslClusterTest.java | 74 ++--
...ItSqlReplCommandNotInitializedClusterTest.java} | 8 +-
.../java/org/apache/ignite/internal/cli/Main.java | 1 +
.../apache/ignite/internal/cli/ReplManager.java | 8 +-
.../internal/cli/call/connect/ConnectCall.java | 20 +-
.../cli/call/connect/ConnectionChecker.java | 34 +-
.../cli/commands/connect/ConnectCommand.java | 10 +-
.../questions/ConnectToClusterQuestion.java | 23 +-
.../internal/cli/commands/sql/SqlCommand.java | 26 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 17 +-
.../apache/ignite/internal/cli/core/repl/Repl.java | 9 -
.../ignite/internal/cli/core/repl/ReplBuilder.java | 14 -
.../ignite/internal/cli/core/repl/SessionInfo.java | 24 ++
.../cli/core/repl/executor/ReplExecutorImpl.java | 2 -
.../cli/commands/cliconfig/ConfigManagerTest.java | 44 ++-
.../cliconfig/TestConfigManagerHelper.java | 19 ++
.../ignite/internal/client/TcpClientChannel.java | 68 +++-
.../org/apache/ignite/client/ConnectionTest.java | 2 +
.../management/ClusterManagementGroupManager.java | 11 +-
.../internal/future/timeout/TimeoutObject.java} | 23 +-
.../internal/future/timeout/TimeoutWorker.java | 109 ++++++
.../RebalanceRaftGroupEventsListener.java | 13 +-
.../ZoneRebalanceRaftGroupEventsListener.java | 66 +---
modules/index/build.gradle | 1 +
...IndexNodeFinishedRwTransactionsCheckerTest.java | 35 +-
.../internal/network/DefaultMessagingService.java | 65 +++-
.../replicator/ItReplicaLifecycleTest.java | 2 +-
.../replicator/utils/TestPlacementDriver.java | 21 +-
.../PartitionReplicaLifecycleManager.java | 27 +-
.../apache/ignite/internal/raft/RaftManager.java | 9 +
.../apache/ignite/internal/raft/ItLozaTest.java | 111 ++++--
.../raft/ItTruncateSuffixAndRestartTest.java | 11 +-
.../internal/raft/CoreLogStorageBudgetsModule.java | 4 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 19 +-
.../ignite/internal/raft/server/RaftServer.java | 8 +
.../internal/raft/server/impl/JraftServerImpl.java | 28 +-
.../internal/raft/storage/LogStorageFactory.java | 7 +
.../storage/impl/DefaultLogStorageFactory.java | 11 +
.../raft}/storage/impl/EntryCountBudget.java | 2 +-
.../raft/storage/impl/LocalLogStorageFactory.java | 5 +
.../raft}/storage/impl/LogStorageBudget.java | 2 +-
.../raft}/storage/impl/LogStorageException.java | 8 +-
.../jraft => internal/raft}/storage/impl/Logs.java | 25 +-
.../raft}/storage/impl/OnHeapLogs.java | 2 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 21 +-
.../impl/RocksDbSharedLogStorageUtils.java} | 28 +-
.../raft}/storage/impl/RocksDbSpillout.java | 26 +-
.../raft}/storage/impl/UnlimitedBudget.java | 2 +-
.../raft}/storage/impl/VolatileLogStorage.java | 4 +-
.../storage/impl/VolatileLogStorageFactory.java | 16 +-
.../storage/impl/VolatileRaftMetaStorage.java | 2 +-
.../raft/storage/logit/LogitLogStorageFactory.java | 13 +
.../raft/jraft/core/LogStorageBudgetFactory.java | 4 +-
.../raft/jraft/core/LogStorageBudgetsModule.java | 2 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 29 +-
.../raft/CoreLogStorageBudgetsModuleTest.java | 11 +-
.../storage/impl/RocksDbSharedLogStorageTest.java | 25 +-
.../impl/SharedVsNonSharedLogStorageBenchmark.java | 23 +-
.../impl/VolatileLogStorageSpecificsTest.java | 2 +-
.../jraft/storage/impl/EntryCountBudgetTest.java | 1 +
.../jraft/storage/impl/UnlimitedBudgetTest.java | 1 +
.../impl/VolatileLogStorageBudgetingTest.java | 3 +
.../jraft/storage/impl/VolatileLogStorageTest.java | 3 +
.../storage/impl/VolatileRaftMetaStorageTest.java | 13 +-
.../jraft/storage/logit/LogitLogStorageTest.java | 23 +-
.../ignite/internal/replicator/ReplicaManager.java | 2 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 208 +++++++++++
.../internal/sql/engine/ItAggregatesTest.java | 4 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 3 +
.../engine/ItSqlUsesSelectCountOptimizedTest.java | 149 ++++++++
.../ignite/internal/sql/sqllogic/EndFor.java} | 23 +-
.../apache/ignite/internal/sql/sqllogic/For.java | 165 +++++++++
.../apache/ignite/internal/sql/sqllogic/Loop.java | 18 +-
.../apache/ignite/internal/sql/sqllogic/Query.java | 15 +-
.../ignite/internal/sql/sqllogic/Script.java | 2 +
.../internal/sql/sqllogic/ScriptContext.java | 22 +-
.../ignite/internal/sql/sqllogic/Statement.java | 21 +-
.../src/integrationTest/sql/_runner/self.test | 30 +-
.../integrationTest/sql/_runner/self_for_loop.test | 101 ++++++
.../aggregates/test_aggregate_types_scalar.test | 4 +-
.../integrationTest/sql/cast/test_cast_bigint.test | 66 +---
.../sql/cast/test_cast_decimal.test | 93 +----
.../integrationTest/sql/cast/test_cast_double.test | 51 +--
.../integrationTest/sql/cast/test_cast_float.test | 44 +--
.../integrationTest/sql/cast/test_cast_int.test | 69 +---
.../integrationTest/sql/cast/test_cast_real.test | 45 +--
.../sql/cast/test_cast_smallint.test | 69 +---
.../sql/cast/test_cast_tinyint.test | 69 +---
.../sql/engine/exec/LogicalRelImplementor.java | 6 +
.../internal/sql/engine/exec/ScannableTable.java | 3 +
.../sql/engine/exec/ScannableTableImpl.java | 5 +
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 2 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 21 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 6 +
.../sql/engine/prepare/IgniteRelShuttle.java | 7 +
.../internal/sql/engine/prepare/MultiStepPlan.java | 18 +-
.../internal/sql/engine/prepare/PlannerHelper.java | 168 +++++++++
.../sql/engine/prepare/PlanningContext.java | 21 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 102 +++++-
.../sql/engine/prepare/SelectCountPlan.java | 184 ++++++++++
.../engine/prepare/pruning/ModifyNodeVisitor.java | 6 +
.../internal/sql/engine/rel/IgniteRelVisitor.java | 5 +
.../internal/sql/engine/rel/IgniteSelectCount.java | 142 ++++++++
.../sql/engine/exec/ExecutionServiceImplTest.java | 52 ++-
.../sql/engine/exec/mapping/MappingTestRunner.java | 2 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 5 +
.../exec/rel/IndexScanNodeExecutionTest.java | 5 +
.../sql/engine/framework/DataProvider.java | 21 +-
.../sql/engine/framework/TestBuilders.java | 15 +
.../sql/engine/framework/TestClusterTest.java | 21 +-
.../internal/sql/engine/framework/TestNode.java | 40 ++-
.../sql/engine/planner/AbstractPlannerTest.java | 2 +
.../sql/engine/planner/SelectCountPlannerTest.java | 379 +++++++++++++++++++++
.../internal/sql/engine/util/QueryCheckerTest.java | 2 +
.../resources/mapping/test_partition_pruning.test | 26 ++
125 files changed, 3317 insertions(+), 1172 deletions(-)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/connect/ItConnectNonReplCommandTest.java
delete mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/questions/ItConnectToBasicAuthClusterTest.java
rename
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/sql/{ItSqlReplCommandNotInitialedClusterTest.java
=> ItSqlReplCommandNotInitializedClusterTest.java} (92%)
copy
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/core/LogStorageBudgetsModule.java
=>
core/src/main/java/org/apache/ignite/internal/future/timeout/TimeoutObject.java}
(64%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/future/timeout/TimeoutWorker.java
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/EntryCountBudget.java (98%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/LogStorageBudget.java (97%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/LogStorageException.java (84%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/Logs.java (65%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/OnHeapLogs.java (97%)
copy
modules/raft/src/main/java/org/apache/ignite/{raft/jraft/core/LogStorageBudgetFactory.java
=> internal/raft/storage/impl/RocksDbSharedLogStorageUtils.java} (59%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/RocksDbSpillout.java (92%)
copy modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/UnlimitedBudget.java (95%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/VolatileLogStorage.java (99%)
rename modules/raft/src/main/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/VolatileRaftMetaStorage.java (97%)
rename modules/raft/src/test/java/org/apache/ignite/{raft/jraft =>
internal/raft}/storage/impl/VolatileLogStorageSpecificsTest.java (99%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/FutureTimeoutBenchmark.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlUsesSelectCountOptimizedTest.java
rename
modules/{raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/UnlimitedBudget.java
=>
sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/sqllogic/EndFor.java}
(56%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/sqllogic/For.java
create mode 100644
modules/sql-engine/src/integrationTest/sql/_runner/self_for_loop.test
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/SelectCountPlan.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteSelectCount.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/SelectCountPlannerTest.java
