You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2025/07/02 11:32:57 UTC
(ignite-3) branch ignite-25575 updated (c933545a986 -> 67ec6300866)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-25575
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit c933545a986 Add naive annotation validation. Implement compatibility validation. Relax tree equality validation.
omit 87f02674e91 Minor
add 05219382236 IGNITE-25792 Fix LeaseTracker's event generation (#6150)
add 787d9b2f448 IGNITE-25786 Fix ItRebalanceDistributedTest.testRebalanceWithTheSameNodes (#6148)
add 3482d188e0a GG-43303 Move dependency constraint to libs.versions.toml (#6110)
add 1fce76fa7b4 IGNITE-25257 .NET: Optimize platform job execution (#6120)
add 88ee6608cfd IGNITE-25782 Handle stopping replica when the colocation is enabled (#6136)
add c8137d7fb69 IGNITE-25796 Fix ItCompatibilityTest#testCompatibility for MAC (#6154)
add 2320b5f5307 IGNITE-25795 Convert planned to pending queue on assignments stable swich (#6153)
add 83c55b6337d IGNITE-25713 .NET: Fix ConnectAllSockets error handling race condition (#6155)
add 78fab62cab9 IGNITE-25762 MetricExporters refactoring (#6113)
add c7c8e285c4d IGNITE-25799 Fix flaky ItPrimaryReplicaChoiceTest#testPrimaryChangeLongHandling (#6157)
add 8d335ba3ef0 Bump value from 2.10.1 to 2.11.0 (#6158)
add 719ad053065 Bump testcontainers from 1.21.2 to 1.21.3 (#6159)
add f2da56deb9a IGNITE-24459 .NET: Enable API compatibility check for NuGet packages (#6162)
add d90e159be8d IGNITE-25741 Throttle cleanups on recovery (#6099)
add d13fb033715 IGNITE-25810 Revert `com.netflix.nebula.ospackage` version bump (#6165)
add a7968897183 IGNITE-24942 Schedule rebalance retries after a delay (#6167)
add 1e667ffe610 IGNITE-25255 Sql. Bump calcite version to 1.40 (#6128)
add 8bb6655e93b IGNITE-21874 Log OS info to the server log at startup (#6174)
add fa54e984adb IGNITE-25531 Sql. Remove Limit if there is Sort with fetch (#6140)
add 0f716aba6a0 Minor
add f8418ce9cb5 Add naive annotation validation. Implement compatibility validation. Relax tree equality validation.
add 67ec6300866 minor after review
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 (c933545a986)
\
N -- N -- N refs/heads/ignite-25575 (67ec6300866)
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:
build.gradle | 6 +
gradle/libs.versions.toml | 12 +-
.../handler/ClientInboundMessageHandler.java | 12 +-
.../ignite/internal/client/TcpIgniteClient.java | 1 +
.../apache/ignite/client/ClientMetricsTest.java | 13 +-
.../apache/ignite/client/fakes/FakeCompute.java | 5 +-
.../internal/deployunit/DeploymentManagerImpl.java | 10 +-
.../internal/compute/ComputeComponentImpl.java | 2 +-
.../ignite/internal/compute/ComputeUtils.java | 2 +-
.../internal/compute/JobExecutionContextImpl.java | 7 +-
.../compute/executor/ComputeExecutorImpl.java | 15 +
.../platform/dotnet/DotNetComputeExecutor.java | 32 ++
.../internal/compute/loader/JobClassLoader.java | 106 ++----
.../compute/loader/JobClassLoaderFactory.java | 78 +---
...JobClassLoader.java => JobClassLoaderImpl.java} | 47 +--
...obClassLoaderFactory.java => JobClasspath.java} | 39 +-
.../compute/streamer/StreamerReceiverJob.java | 2 +-
.../internal/compute/ComputeComponentImplTest.java | 3 +-
.../compute/JobExecutionContextImplTest.java | 4 +-
.../compute/executor/ComputeExecutorTest.java | 3 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 35 +-
.../compute/loader/JobClassLoaderTest.java | 21 +-
.../compute/loader/JobContextManagerTest.java | 4 +-
.../apache/ignite/internal/util/GridUnsafe.java | 2 +-
.../rebalance/ItRebalanceDistributedTest.java | 28 +-
.../rebalance/PartitionMover.java | 24 +-
.../RebalanceRaftGroupEventsListener.java | 11 +-
.../ZoneRebalanceRaftGroupEventsListener.java | 11 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 8 +-
.../exporters/otlp/OtlpPushMetricExporter.java | 13 +-
modules/metrics/build.gradle | 1 +
.../metrics/exporters/TestDoubleStartExporter.java | 22 +-
.../metrics/exporters/TestPullMetricExporter.java | 13 +-
.../metrics/exporters/TestPushMetricExporter.java | 7 +-
.../metrics/exporters/TestSimpleExporter.java | 15 +-
.../ignite/internal/metrics/MetricManager.java | 2 +-
.../ignite/internal/metrics/MetricManagerImpl.java | 160 +++++---
.../ignite/internal/metrics/MetricProvider.java | 19 +-
.../ignite/internal/metrics/MetricRegistry.java | 27 +-
.../metrics/exporters/BasicMetricExporter.java | 41 +--
.../internal/metrics/exporters/MetricExporter.java | 7 +-
.../metrics/exporters/PushMetricExporter.java | 43 ++-
.../metrics/exporters/jmx/JmxExporter.java | 22 +-
.../metrics/exporters/log/LogPushExporter.java | 7 +-
.../internal/metrics/MetricEntitiesTest.java | 34 +-
.../metrics/exporters/PushExporterTest.java | 9 +-
.../internal/metrics/exporters/TestExporter.java | 30 +-
.../ignite/internal/metrics/NoOpMetricManager.java | 2 +-
.../ignite/internal/metrics/TestMetricManager.java | 4 +-
.../PendingAssignmentsCalculator.java | 2 +-
.../PartitionReplicaLifecycleManager.java | 5 +-
.../handlers/TxCleanupRecoveryRequestHandler.java | 63 +++-
.../PartitionReplicaLifecycleManagerTest.java | 1 +
.../TxCleanupRecoveryRequestHandlerTest.java | 76 ++++
modules/placement-driver/build.gradle | 2 +
.../ItPrimaryReplicaChoiceTest.java | 28 +-
.../placementdriver/leases/LeaseTracker.java | 170 +++++----
.../internal/placementdriver/LeaseTrackerTest.java | 148 ++++++--
.../Compute/ComputeJobExecutorBenchmarks.cs | 6 +-
.../Compute/PlatformJobBenchmarks.cs | 24 +-
.../Compute/Executor/JobLoadContextCacheTests.cs | 131 +++++++
.../TestHelpers/ManagementApi.cs | 4 +-
.../dotnet/Apache.Ignite/Apache.Ignite.csproj | 3 -
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 115 ++++++
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 32 +-
.../Apache.Ignite/Internal/ClientSocket.Server.cs | 7 +-
.../Compute/Executor/ComputeJobExecutor.cs | 54 ++-
.../Compute/Executor/DeploymentUnitPaths.cs | 3 +-
.../Internal/Compute/Executor/JobLoadContext.cs | 49 ++-
.../Compute/Executor/JobLoadContextCache.cs | 241 ++++++++++++
modules/platforms/dotnet/Directory.Build.props | 6 +
.../ignite/internal/raft/RaftGroupServiceImpl.java | 79 ++--
.../replicator/ZonePartitionReplicaImpl.java | 5 +-
.../ignite/internal/table/ItReplicasTest.java | 10 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 13 +-
.../ignite/internal/app/IgniteServerImpl.java | 22 ++
.../ignite/internal/app/ThreadPoolsManager.java | 5 -
.../compatibility/framework/ConfigNode.java | 12 +-
.../framework/ConfigurationTreeScanner.java | 2 +-
.../compatibility/configuration/snapshot.bin | Bin 3487 -> 3357 bytes
modules/sql-engine/build.gradle | 6 -
.../sql/group1/explain/sort_and_limit.test | 42 +--
.../timestamp/test_incorrect_timestamp_ltz.test | 5 +-
.../internal/sql/engine/exec/exp/RexImpTable.java | 55 +++
.../sql/engine/exec/exp/RexToLixTranslator.java | 186 +++++++++-
.../sql/engine/exec/exp/agg/Accumulators.java | 42 ++-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 15 +-
.../internal/sql/engine/exec/rel/SortNode.java | 6 +
.../internal/sql/engine/prepare/PlannerPhase.java | 11 +-
.../sql/engine/rel/AbstractIgniteJoin.java | 19 +
.../internal/sql/engine/rel/IgniteLimit.java | 5 +-
.../ignite/internal/sql/engine/rel/IgniteSort.java | 31 --
.../sql/engine/rule/HashJoinConverterRule.java | 8 +-
.../sql/engine/rule/MergeJoinConverterRule.java | 6 +-
.../sql/engine/rule/SortConverterRule.java | 95 +----
.../sql/engine/rule/SortExchangeTransposeRule.java | 92 ++++-
.../internal/sql/engine/rule/SortMergeRule.java | 85 +++++
.../internal/sql/engine/rule/SortRemoveRule.java | 76 ++++
.../rule/logical/IgniteSubQueryRemoveRule.java | 2 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 4 +
.../ignite/internal/sql/engine/util/Commons.java | 20 +
.../ignite/internal/sql/engine/util/RexUtils.java | 3 +-
.../exec/exp/agg/LiteralValAccumulatorTest.java | 15 +-
.../sql/engine/planner/AggregatePlannerTest.java | 6 +-
.../planner/ColocatedHashAggregatePlannerTest.java | 6 +-
.../planner/ColocatedSortAggregatePlannerTest.java | 6 +-
.../sql/engine/planner/LimitOffsetPlannerTest.java | 26 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 6 +-
.../planner/MapReduceSortAggregatePlannerTest.java | 6 +-
.../planner/TpcdsColocatedQueryPlannerTest.java | 5 +
.../sql/engine/sql/IgniteSqlParserSelfTest.java | 6 +-
.../src/test/resources/docs/operator_list.txt | 9 +-
.../src/test/resources/tpcds/plan/q1.plan | 189 +++++-----
.../src/test/resources/tpcds/plan/q10.plan | 253 +++++++------
.../test/resources/tpcds/plan/q10_colocated.plan | 253 +++++++------
.../src/test/resources/tpcds/plan/q15.plan | 91 +++--
.../test/resources/tpcds/plan/q15_colocated.plan | 91 +++--
.../src/test/resources/tpcds/plan/q18.plan | 147 ++++----
.../test/resources/tpcds/plan/q18_colocated.plan | 147 ++++----
.../src/test/resources/tpcds/plan/q19.plan | 123 +++----
.../test/resources/tpcds/plan/q19_colocated.plan | 123 +++----
.../test/resources/tpcds/plan/q1_colocated.plan | 189 +++++-----
.../src/test/resources/tpcds/plan/q22.plan | 71 ++--
.../test/resources/tpcds/plan/q22_colocated.plan | 71 ++--
.../src/test/resources/tpcds/plan/q25.plan | 157 ++++----
.../test/resources/tpcds/plan/q25_colocated.plan | 157 ++++----
.../src/test/resources/tpcds/plan/q3.plan | 79 ++--
.../src/test/resources/tpcds/plan/q30.plan | 213 ++++++-----
.../test/resources/tpcds/plan/q30_colocated.plan | 213 ++++++-----
.../src/test/resources/tpcds/plan/q33.plan | 383 ++++++++++---------
.../test/resources/tpcds/plan/q33_colocated.plan | 383 ++++++++++---------
.../test/resources/tpcds/plan/q3_colocated.plan | 79 ++--
.../src/test/resources/tpcds/plan/q41.plan | 91 +++--
.../test/resources/tpcds/plan/q41_colocated.plan | 91 +++--
.../src/test/resources/tpcds/plan/q42.plan | 73 ++--
.../test/resources/tpcds/plan/q42_colocated.plan | 73 ++--
.../src/test/resources/tpcds/plan/q43.plan | 73 ++--
.../test/resources/tpcds/plan/q43_colocated.plan | 73 ++--
.../src/test/resources/tpcds/plan/q46.plan | 139 ++++---
.../test/resources/tpcds/plan/q46_colocated.plan | 139 ++++---
.../src/test/resources/tpcds/plan/q51.plan | 141 ++++---
.../test/resources/tpcds/plan/q51_colocated.plan | 141 ++++---
.../src/test/resources/tpcds/plan/q52.plan | 79 ++--
.../test/resources/tpcds/plan/q52_colocated.plan | 79 ++--
.../src/test/resources/tpcds/plan/q53.plan | 99 +++--
.../test/resources/tpcds/plan/q53_colocated.plan | 99 +++--
.../src/test/resources/tpcds/plan/q54.plan | 287 +++++++--------
.../test/resources/tpcds/plan/q54_colocated.plan | 287 +++++++--------
.../src/test/resources/tpcds/plan/q55.plan | 79 ++--
.../test/resources/tpcds/plan/q55_colocated.plan | 79 ++--
.../src/test/resources/tpcds/plan/q56.plan | 407 ++++++++++-----------
.../test/resources/tpcds/plan/q56_colocated.plan | 407 ++++++++++-----------
.../src/test/resources/tpcds/plan/q6.plan | 217 ++++++-----
.../src/test/resources/tpcds/plan/q60.plan | 383 ++++++++++---------
.../test/resources/tpcds/plan/q60_colocated.plan | 383 ++++++++++---------
.../src/test/resources/tpcds/plan/q63.plan | 99 +++--
.../test/resources/tpcds/plan/q63_colocated.plan | 99 +++--
.../src/test/resources/tpcds/plan/q65.plan | 173 +++++----
.../test/resources/tpcds/plan/q65_colocated.plan | 173 +++++----
.../src/test/resources/tpcds/plan/q68.plan | 141 ++++---
.../test/resources/tpcds/plan/q68_colocated.plan | 141 ++++---
.../src/test/resources/tpcds/plan/q69.plan | 315 ++++++++--------
.../test/resources/tpcds/plan/q69_colocated.plan | 315 ++++++++--------
.../test/resources/tpcds/plan/q6_colocated.plan | 217 ++++++-----
.../src/test/resources/tpcds/plan/q72.plan | 197 +++++-----
.../test/resources/tpcds/plan/q72_colocated.plan | 197 +++++-----
.../src/test/resources/tpcds/plan/q76.plan | 165 ++++-----
.../test/resources/tpcds/plan/q76_colocated.plan | 165 ++++-----
.../src/test/resources/tpcds/plan/q78.plan | 269 +++++++-------
.../test/resources/tpcds/plan/q78_colocated.plan | 269 +++++++-------
.../src/test/resources/tpcds/plan/q79.plan | 119 +++---
.../test/resources/tpcds/plan/q79_colocated.plan | 119 +++---
.../src/test/resources/tpcds/plan/q81.plan | 213 ++++++-----
.../test/resources/tpcds/plan/q81_colocated.plan | 213 ++++++-----
.../src/test/resources/tpcds/plan/q85.plan | 159 ++++----
.../test/resources/tpcds/plan/q85_colocated.plan | 159 ++++----
.../src/test/resources/tpcds/plan/q89.plan | 101 +++--
.../test/resources/tpcds/plan/q89_colocated.plan | 101 +++--
.../src/test/resources/tpcds/plan/q90.plan | 177 +++++----
.../test/resources/tpcds/plan/q90_colocated.plan | 177 +++++----
.../src/test/resources/tpcds/plan/q93.plan | 91 +++--
.../test/resources/tpcds/plan/q93_colocated.plan | 91 +++--
.../src/test/resources/tpcds/plan/q96.plan | 85 +++--
.../test/resources/tpcds/plan/q96_colocated.plan | 85 +++--
.../src/test/resources/tpch/plan/q10.plan | 109 +++---
.../src/test/resources/tpch/plan/q18.plan | 135 ++++---
.../src/test/resources/tpch/plan/q2.plan | 233 ++++++------
.../src/test/resources/tpch/plan/q21.plan | 227 ++++++------
.../src/test/resources/tpch/plan/q3.plan | 93 +++--
.../internal/table/distributed/TableManager.java | 2 +-
.../table/distributed/PartitionMoverTest.java | 14 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 3 +-
192 files changed, 8578 insertions(+), 7638 deletions(-)
copy modules/compute/src/main/java/org/apache/ignite/internal/compute/loader/{JobClassLoader.java => JobClassLoaderImpl.java} (73%)
copy modules/compute/src/main/java/org/apache/ignite/internal/compute/loader/{JobClassLoaderFactory.java => JobClasspath.java} (66%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/Compute/Executor/JobLoadContextCacheTests.cs
create mode 100644 modules/platforms/dotnet/Apache.Ignite/ApiCompatibilitySuppressions.xml
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Internal/Compute/Executor/JobLoadContextCache.cs
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/SortMergeRule.java
create mode 100644 modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/SortRemoveRule.java