This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-26156
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 03d1da335ee Minor after review. Rearrange code. Get rid of
IgniteSqlInternal class.
omit b654d8dc3d5 wip
omit 60d86b920fe IGNITE-26347 Adjust the rebalancing logic in the case of
empty data nodes (#6572)
omit 56ecde1a897 IGNITE-25918 Fix datarace in ReadWriteTransactionImpl
(#6554)
omit a56e9aabf2e IGNITE-26409 Rename InternalClusterNodeImpl back to
ClusterNodeImpl (#6574)
omit 33fa7b0f3fa IGNITE-26328 Add table metrics (#6544)
omit fc24ebf5b95 Bump netty from 4.2.5.Final to 4.2.6.Final (#6567)
omit a8aec521f2b Bump io.opentelemetry:opentelemetry-exporter-otlp from
1.53.0 to 1.54.0 (#6568)
omit 1da7cad2069 IGNITE-26346 Ban the creation of distribution zones which
don't have data nodes at the moment of creation (#6546)
omit b1fa2f59159 IGNITE-26398 Update RW transaction timeout javadoc (#6562)
omit f8f970e6884 IGNITE-26401 Rename generateCompatibilitySnapshot task
(#6564)
omit abf6e2b30ef IGNITE-26397 OutNetworkObject constructor with
shouldBeSavedForRecovery is redundant (#6561)
omit 1097ec3a005 IGNITE-24458 Java API compatibility extension (#6501)
omit e4b286f7cf3 Bump netty from 4.2.4.Final to 4.2.5.Final (#6558)
omit cffe30fc597 Bump com.github.spotbugs from 6.2.7 to 6.3.0 (#6559)
omit 3c091114464 Bump com.google.testing.compile:compile-testing from
0.21.0 to 0.22.0 (#6560)
omit 55ebe94dab0 IGNITE-25945 Acknowledge messages in batches (#6552)
omit 9221ebe6303 Bump io.dropwizard.metrics:metrics-core from 4.2.34 to
4.2.36 (#6525)
omit 4fb2e4ff001 IGNITE-26388 Add python DB API example (#6550)
omit 5dbd954eb32 Bump io.swagger.parser.v3:swagger-parser from 2.1.32 to
2.1.33 (#6536)
omit 7a6cfd0286a Bump org.jetbrains:annotations from 26.0.2 to 26.0.2-1
(#6526)
omit b7514e218a6 Bump com.github.spotbugs from 6.2.5 to 6.2.7 (#6548)
omit 4ce382816eb IGNITE-26017 Sql. Improve row count estimation for all
join types (#6543)
omit 312f07ac2e6 IGNITE-26374 Update SQL API doc (#6539)
omit 4ead1e5d18a IGNITE-26375 Update compute examples (#6541)
omit 7e328affe13 IGNITE-26370 Add gradle task for updating versions for
compatibility tests (#6540)
omit d169714b99e IGNITE-26367 Improve error message when deployment unit is
not provided (#6532)
omit dd204d737e8 IGNITE-25983 Hash index isn't used with multiple keys
(#6534)
add 5fac2189cbe wip
add 590b86730bb wip
add 25c01aada99 wip
add 75ef86d6e8c styles
add 6b4671db046 styles
add 59aa42f4e3f Minor after review. Rearrange code. Get rid of
IgniteSqlInternal class.
add 54557c1b409 Minor after review. Add unit test. Fix implementation.
add 769a98e1df3 Minor after review. Fix compatibility for REPL command.
add 5cc2b411ff4 minor
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (03d1da335ee)
\
N -- N -- N refs/heads/ignite-26156 (5cc2b411ff4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
RELEASE.md | 6 +-
check-rules/checkstyle-rules.xml | 2 +-
docs/_docs/developers-guide/compute/compute.adoc | 96 ++--
docs/_docs/developers-guide/sql/sql-api.adoc | 4 +-
.../example/compute/ComputeBroadcastExample.java | 21 +-
.../example/compute/ComputeJobPriorityExample.java | 2 +-
.../example/compute/ComputeJobStateExample.java | 104 ----
examples/python/db_api_example.py | 145 -----
gradle/libs.versions.toml | 17 +-
.../org/apache/ignite/tx/TransactionOptions.java | 6 +-
.../compaction/ItCatalogCompactionTest.java | 4 +-
.../CatalogCompactionRunnerSelfTest.java | 4 +-
.../catalog/ItCatalogApiThreadingTest.java | 3 +-
.../ignite/internal/catalog/ItCatalogDslTest.java | 3 +-
.../commands/sql/CliSqlConnectCommandTestBase.java | 7 -
.../cli/commands/sql/ItSqlCommandTest.java | 42 +-
.../cli/commands/sql/ItSqlConnectBasicTest.java | 4 +-
.../cli/commands/sql/ItSqlConnectSslBasicTest.java | 4 +-
.../cli/commands/sql/ItSqlConnectSslTest.java | 4 +-
.../cli/commands/sql/ItSqlConnectTest.java | 2 +-
.../cli/commands/sql/ItSqlMultistatementTest.java | 20 +-
.../ItSqlReplCommandNotInitializedClusterTest.java | 11 +-
.../internal/cli/commands/sql/SqlCommand.java | 98 +---
.../sql/{SqlCommand.java => SqlExecCommand.java} | 11 +-
...SqlReplCommand.java => SqlExecReplCommand.java} | 12 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 243 +-------
.../commands/sql/planner/SqlPlannerCommand.java | 2 -
...SqlCommandTest.java => SqlExecCommandTest.java} | 4 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 4 +-
.../java/org/apache/ignite/client/TestServer.java | 4 +-
.../apache/ignite/client/fakes/FakeCompute.java | 4 +-
.../ignite/client/fakes/FakeInternalTable.java | 10 +-
.../management/ClusterManagementGroupManager.java | 4 +-
.../raft/commands/ClusterNodeMessage.java | 4 +-
.../management/topology/api/LogicalNode.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 28 +-
.../management/raft/CmgRaftServiceTest.java | 4 +-
modules/compatibility-tests/build.gradle | 37 +-
.../ignite/internal/ItApiCompatibilityTest.java | 52 --
.../ignite/internal/OpenApiCompatibilityTest.java | 3 +-
.../versions/{3.0.0 => 3_0_0}/openapi.yaml | 0
.../org/apache/ignite/internal/Dependencies.java | 149 -----
.../org/apache/ignite/internal/IgniteCluster.java | 47 +-
.../apache/ignite/internal/OldClientLoader.java | 2 +-
.../api/ApiCompatibilityExtension.java | 68 ---
.../compatibility/api/ApiCompatibilityTest.java | 77 ---
.../api/ApiCompatibilityTestInvocationContext.java | 43 --
.../compatibility/api/CompatibilityChecker.java | 135 -----
.../compatibility/api/CompatibilityExtension.java | 55 --
.../compatibility/api/CompatibilityInput.java | 62 --
.../compatibility/api/CompatibilityOutput.java | 50 --
.../internal/compatibility/api/MethodProvider.java | 104 ----
.../compatibility/api/TestNameFormatter.java | 41 --
.../src/testFixtures/resources/igniteVersions.json | 2 +-
.../internal/compute/ItComputeTestStandalone.java | 98 ++--
.../internal/compute/utils/InteractiveJobs.java | 4 +-
.../internal/compute/ComputeComponentImpl.java | 3 +-
.../ignite/internal/compute/ComputeUtils.java | 12 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 4 +-
.../internal/compute/executor/ComputeExecutor.java | 4 +-
.../compute/executor/ComputeExecutorImpl.java | 7 +-
.../internal/compute/ComputeComponentImplTest.java | 6 +-
.../internal/compute/IgniteComputeImplTest.java | 6 +-
.../compute/loader/JobClassLoaderTest.java | 10 +-
.../ItDistributionZonesFiltersTest.java | 83 +--
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 3 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 8 +-
.../DistributionZoneRebalanceEngineV2.java | 8 +-
.../distributionzones/rebalance/RebalanceUtil.java | 2 +-
.../rebalance/ZoneRebalanceUtil.java | 2 +-
.../DistributionZoneManagerAlterFilterTest.java | 12 +-
.../DistributionZoneManagerFilterTest.java | 12 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 4 +-
...butionZoneManagerStorageProfilesFilterTest.java | 12 +-
.../DistributionZoneCausalityDataNodesTest.java | 8 +-
.../DistributionZonesTestUtil.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 6 +-
.../apache/ignite/internal/index/IndexManager.java | 4 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 4 +-
.../internal/index/IndexManagementUtilsTest.java | 8 +-
.../internal/index/TestIndexManagementUtils.java | 4 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 4 +-
.../MetaStorageLeaderElectionListenerTest.java | 6 +-
.../impl/MetaStorageManagerRecoveryTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 4 +-
.../internal/network/ClusterNodeSerializer.java | 2 +-
...rNodeImpl.java => InternalClusterNodeImpl.java} | 12 +-
.../network/InternalClusterNodeSerializerTest.java | 2 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 6 +-
.../network/netty/ItConnectionManagerTest.java | 42 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 106 +---
.../internal/network/DefaultMessagingService.java | 2 +-
.../internal/network/NettyBootstrapFactory.java | 10 -
.../ignite/internal/network/OutNetworkObject.java | 13 +-
.../configuration/AckConfigurationSchema.java | 48 --
.../configuration/NetworkConfigurationSchema.java | 4 -
.../network/message/ClusterNodeMessage.java | 4 +-
.../internal/network/netty/ConnectionManager.java | 6 +-
.../network/netty/InboundRecoveryHandler.java | 67 +--
.../ignite/internal/network/netty/NettySender.java | 4 +-
.../internal/network/netty/PipelineUtils.java | 9 +-
.../network/recovery/HandshakeManagerUtils.java | 2 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 14 +-
.../RecoveryInitiatorHandshakeManager.java | 14 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 4 +-
.../scalecube/ScaleCubeTopologyService.java | 4 +-
.../network/DefaultMessagingServiceTest.java | 33 +-
.../internal/network/OutNetworkObjectTest.java | 2 +-
.../network/netty/RecoveryHandshakeTest.java | 40 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 15 +-
.../network/recovery/RecoveryDescriptorTest.java | 6 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 19 +-
.../partition/replicator/fixtures/Node.java | 3 +-
.../PartitionReplicaLifecycleManagerTest.java | 4 +-
.../ItPrimaryReplicaChoiceTest.java | 6 +-
.../placementdriver/PlacementDriverTest.java | 6 +-
.../Transactions/TransactionOptions.cs | 4 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 2 +
.../ignite/internal/raft/RaftGroupServiceTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 4 +-
.../replicator/PlacementDriverReplicaSideTest.java | 6 +-
.../internal/replicator/ReplicaManagerTest.java | 4 +-
modules/runner/build.gradle | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 3 +-
.../internal/table/ItReadOnlyTransactionTest.java | 6 +-
.../ignite/internal/table/ItTableScanTest.java | 8 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../ConfigurationCompatibilityTest.java | 6 +-
.../configuration/ignite-snapshot.bin | Bin 5581 -> 5511 bytes
.../internal/sql/api/ItSqlAlterZoneTest.java | 55 --
.../internal/sql/api/ItSqlCreateZoneTest.java | 17 -
.../internal/sql/engine/ItSecondaryIndexTest.java | 17 -
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../sql/engine/metadata/IgniteMdRowCount.java | 98 +---
.../ddl/ClusterWideNodeFilterValidator.java | 87 ---
.../prepare/ddl/DdlSqlToCommandConverter.java | 44 +-
.../engine/prepare/ddl/NodeFilterValidator.java | 36 --
.../prepare/ddl/StorageProfileValidator.java | 3 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 230 ++++----
.../sql/engine/exec/ExecutionServiceImplTest.java | 9 +-
.../sql/engine/exec/PartitionProvidersTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 14 +-
.../exec/rel/TableScanNodeExecutionTest.java | 9 +-
.../engine/framework/ClusterServiceFactory.java | 6 +-
.../sql/engine/framework/NoOpTransaction.java | 4 +-
.../sql/engine/framework/TestBuilders.java | 2 +-
.../sql/engine/planner/DmlPlannerTest.java | 6 +-
.../planner/IndexSearchBoundsPlannerTest.java | 91 +--
.../engine/planner/JoinRowCountEstimationTest.java | 210 +------
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 2 +-
.../DistributionZoneSqlToCommandConverterTest.java | 9 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 4 +-
.../engine/util/IgniteSqlDateTimeUtilsTest.java | 4 +-
.../src/test/resources/tpcds/plan/q14.plan | 214 -------
.../test/resources/tpcds/plan/q14_colocated.plan | 214 -------
.../src/test/resources/tpcds/plan/q23.plan | 87 ---
.../test/resources/tpcds/plan/q23_colocated.plan | 87 ---
.../src/test/resources/tpcds/plan/q24.plan | 46 --
.../test/resources/tpcds/plan/q24_colocated.plan | 46 --
.../src/test/resources/tpcds/plan/q40.plan | 45 +-
.../test/resources/tpcds/plan/q40_colocated.plan | 45 +-
.../src/test/resources/tpcds/plan/q5.plan | 61 +-
.../test/resources/tpcds/plan/q5_colocated.plan | 52 +-
.../src/test/resources/tpcds/plan/q72.plan | 153 ++---
.../test/resources/tpcds/plan/q72_colocated.plan | 153 ++---
.../src/test/resources/tpcds/plan/q75.plan | 40 +-
.../test/resources/tpcds/plan/q75_colocated.plan | 40 +-
.../src/test/resources/tpcds/plan/q77.plan | 16 +-
.../test/resources/tpcds/plan/q77_colocated.plan | 16 +-
.../src/test/resources/tpcds/plan/q78.plan | 106 ++--
.../test/resources/tpcds/plan/q78_colocated.plan | 106 ++--
.../src/test/resources/tpcds/plan/q80.plan | 155 ++---
.../test/resources/tpcds/plan/q80_colocated.plan | 155 ++---
.../src/test/resources/tpcds/plan/q93.plan | 62 +-
.../test/resources/tpcds/plan/q93_colocated.plan | 62 +-
.../src/test/resources/tpch/plan/q13.plan | 31 +-
.../system/SystemDisasterRecoveryManagerImpl.java | 1 -
.../disaster/system/MetastorageRepairImplTest.java | 10 +-
.../SystemDisasterRecoveryManagerImplTest.java | 12 +-
.../internal/systemview/SystemViewManagerTest.java | 4 +-
modules/table/build.gradle | 1 -
...xDistributedTestSingleNodeNoCleanupMessage.java | 5 +-
.../ignite/internal/table/ItColocationTest.java | 5 +-
.../internal/table/metrics/ItTableMetricsTest.java | 631 ---------------------
.../ignite/internal/table/InternalTable.java | 8 -
.../apache/ignite/internal/table/TableImpl.java | 6 -
.../ignite/internal/table/TableViewInternal.java | 8 -
.../internal/table/distributed/TableManager.java | 45 +-
.../replicator/PartitionReplicaListener.java | 161 +-----
.../distributed/storage/InternalTableImpl.java | 12 +-
.../internal/table/metrics/TableMetricSource.java | 222 --------
.../distributed/TableManagerRecoveryTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 5 +-
...itionReplicaListenerSortedIndexLockingTest.java | 5 +-
.../replication/PartitionReplicaListenerTest.java | 11 +-
.../ZonePartitionReplicaListenerTest.java | 11 +-
.../storage/InternalTableEstimatedSizeTest.java | 8 +-
.../distributed/storage/InternalTableImplTest.java | 9 +-
.../table/metrics/TableMetricSourceTest.java | 65 ---
.../apache/ignite/distributed/ItTxTestCluster.java | 7 +-
.../ignite/internal/table/TxAbstractTest.java | 6 +-
.../table/impl/DummyInternalTableImpl.java | 12 +-
.../ignite/internal/tx/ItTxTimeoutOneNodeTest.java | 2 +
.../tx/distributed/ItTransactionRecoveryTest.java | 4 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 12 -
.../apache/ignite/internal/tx/TxCleanupTest.java | 6 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 6 +-
.../internal/tx/impl/OrphanDetectorTest.java | 6 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 4 +-
214 files changed, 1570 insertions(+), 5526 deletions(-)
delete mode 100644
examples/java/src/main/java/org/apache/ignite/example/compute/ComputeJobStateExample.java
delete mode 100644 examples/python/db_api_example.py
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/sql/{SqlCommand.java
=> SqlExecCommand.java} (93%)
copy
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/sql/{SqlReplCommand.java
=> SqlExecReplCommand.java} (96%)
rename
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/sql/{SqlCommandTest.java
=> SqlExecCommandTest.java} (95%)
delete mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/ItApiCompatibilityTest.java
rename modules/compatibility-tests/src/test/resources/versions/{3.0.0 =>
3_0_0}/openapi.yaml (100%)
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/Dependencies.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityExtension.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityTest.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/ApiCompatibilityTestInvocationContext.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityChecker.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityExtension.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityInput.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/CompatibilityOutput.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/MethodProvider.java
delete mode 100644
modules/compatibility-tests/src/testFixtures/java/org/apache/ignite/internal/compatibility/api/TestNameFormatter.java
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterNodeImpl.java
=> InternalClusterNodeImpl.java} (85%)
delete mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/configuration/AckConfigurationSchema.java
delete mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/api/ItSqlAlterZoneTest.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/ClusterWideNodeFilterValidator.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/ddl/NodeFilterValidator.java
delete mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/metrics/ItTableMetricsTest.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/metrics/TableMetricSource.java
delete mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/metrics/TableMetricSourceTest.java
