This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-21609
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 952df86419 styles
add 9cddbc74da IGNITE-21640 Exchange with ClusterNode instances on
handshake (#3326)
add 8c48382f1b IGNITE-21647 Fix NettyServerTest flapping
NullPointerException (#3331)
add f427151f50 IGNITE-21653 Fix a PMD warning that there is unknown rule
(#3334)
add 7f6aa16d72 IGNITE-21497 Clarify compute API (#3190)
add 40d14534bc IGNITE-20296 Make a network message handler that would be
able to accept ClusterNode as a sender (#3329)
add b0255aa6e0 IGNITE-21645 Fix tests extending AbstractPlannerTest on
Java 21 (#3330)
add 525aaabcdc Bump io.swagger.core.v3:swagger-annotations from 2.2.15 to
2.2.20 (#3323)
add 190c63f2d1 IGNITE-21654 Fix flaky client compute tests due to
"unpacker is closed" error (#3343)
add 5db7920c6c IGNITE-21658 Make LowWatermark a top level component (#3340)
add ec32287afb Merge branch 'main' into ignite-21609
No new revisions were added by this update.
Summary of changes:
check-rules/pmd-rules.xml | 33 ++-
gradle/libs.versions.toml | 2 +-
.../org/apache/ignite/compute/IgniteCompute.java | 312 ++++++++++++++++++---
.../ClientComputeExecuteColocatedRequest.java | 2 +-
.../handler}/ClientResourceRegistryTest.java | 4 +-
.../apache/ignite/client/ClientOperationType.java | 2 +-
.../internal/client/compute/ClientCompute.java | 50 ++--
.../client/compute/ClientJobExecution.java | 6 +-
.../internal/client/compute/SubmitResult.java} | 30 +-
.../apache/ignite/client/ClientComputeTest.java | 43 ++-
.../ignite/client/PartitionAwarenessTest.java | 8 +-
.../apache/ignite/client/RequestBalancingTest.java | 3 +-
.../apache/ignite/client/ServerMetricsTest.java | 8 +-
.../apache/ignite/client/fakes/FakeCompute.java | 14 +-
.../management/ClusterManagementGroupManager.java | 14 +-
.../deployunit/DeployMessagingService.java | 14 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 28 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 4 +-
.../internal/compute/ItComputeTestEmbedded.java | 22 +-
.../internal/compute/ItComputeTestStandalone.java | 18 +-
.../internal/compute/ItExecutionsCleanerTest.java | 2 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 2 +-
.../internal/compute/ItWorkerShutdownTest.java | 6 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 14 +-
.../compute/messaging/ComputeMessaging.java | 114 +++-----
.../internal/compute/ComputeComponentImplTest.java | 58 ++--
.../internal/compute/IgniteComputeImplTest.java | 33 ++-
.../internal/testframework/IgniteTestUtils.java | 17 --
.../network/file/FileTransferServiceImpl.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 17 +-
.../network/file/TestMessagingService.java | 8 +-
.../internal/network/file/TestTopologyService.java | 4 +-
.../IndexNodeFinishedRwTransactionsChecker.java | 9 +-
.../internal/network/NetworkMessageHandler.java | 6 +-
.../network/TrackableNetworkMessageHandler.java | 5 +-
.../network/netty/ItConnectionManagerTest.java | 8 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 18 +-
.../internal/network/DefaultMessagingService.java | 18 +-
.../internal/network/NetworkMessageTypes.java | 6 +
.../network/message}/ClusterNodeMessage.java | 18 +-
.../internal/network/message/InvokeResponse.java | 2 +-
.../internal/network/netty/ConnectionManager.java | 55 ++--
.../internal/network/netty/HandshakeHandler.java | 7 +-
.../internal/network/netty/InNetworkObject.java | 28 +-
.../internal/network/netty/MessageHandler.java | 17 +-
.../ignite/internal/network/netty/NettyServer.java | 3 +-
.../network/recovery/HandshakeManagerUtils.java | 11 +
.../recovery/RecoveryClientHandshakeManager.java | 61 ++--
.../RecoveryClientHandshakeManagerFactory.java | 15 +-
.../recovery/RecoveryServerHandshakeManager.java | 50 ++--
.../recovery/message/HandshakeStartMessage.java | 17 +-
.../message/HandshakeStartResponseMessage.java | 23 +-
.../network/recovery/message/InternalMessage.java | 1 -
.../scalecube/ScaleCubeClusterServiceFactory.java | 55 +++-
.../ScaleCubeDirectMarshallerTransport.java | 20 +-
.../network/DefaultMessagingServiceTest.java | 31 +-
.../internal/network/netty/NettyServerTest.java | 23 +-
.../network/netty/RecoveryHandshakeTest.java | 13 +-
.../RecoveryClientHandshakeManagerTest.java | 24 +-
.../RecoveryServerHandshakeManagerTest.java | 20 +-
.../MultiActorPlacementDriverTest.java | 2 +-
.../internal/placementdriver/LeaseUpdater.java | 4 +-
.../cpp/ignite/client/compute/compute.cpp | 12 +-
.../platforms/cpp/ignite/client/compute/compute.h | 18 +-
.../ignite/client/detail/compute/compute_impl.cpp | 4 +-
.../ignite/client/detail/compute/compute_impl.h | 8 +-
.../cpp/tests/client-test/compute_test.cpp | 12 +-
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 2 +-
.../Compute/ComputeClusterAwarenessTests.cs | 10 +-
.../Compute/ComputeTestExtensions.cs | 16 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 92 +++---
.../PartitionAwarenessRealClusterTests.cs | 2 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 8 +-
.../Proto/ColocationHashTests.cs | 4 +-
.../Table/SchemaSynchronizationTest.cs | 6 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 2 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 16 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 8 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 8 +-
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 8 +-
.../AbstractTopologyAwareGroupServiceTest.java | 3 +-
.../rest/compute/ItComputeControllerTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 11 +-
.../runner/app/client/ItThinClientComputeTest.java | 83 +++---
.../client/ItThinClientPartitionAwarenessTest.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 16 +-
.../sql/engine/message/MessageServiceImpl.java | 5 +-
.../engine/exec/exp/IgniteSqlFunctionsTest.java | 5 +-
.../engine/framework/ClusterServiceFactory.java | 21 +-
.../rebalance/ItRebalanceDistributedTest.java | 16 +-
.../internal/table/distributed/LowWatermark.java | 81 ++++--
.../distributed/LowWatermarkChangedListener.java} | 17 +-
.../internal/table/distributed/TableManager.java | 19 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 8 +-
.../outgoing/OutgoingSnapshotsManager.java | 14 +-
.../table/distributed/LowWatermarkTest.java | 25 +-
.../table/distributed/TableManagerTest.java | 5 +-
.../internal/table/distributed/gc/MvGcTest.java | 28 +-
.../table/impl/DummyInternalTableImpl.java | 10 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 5 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 2 +-
.../worker/ItCriticalWorkerMonitoringTest.java | 2 +-
103 files changed, 1203 insertions(+), 882 deletions(-)
rename modules/client-handler/src/test/java/{ =>
org/apache/ignite/client/handler}/ClientResourceRegistryTest.java (96%)
copy
modules/{network/src/main/java/org/apache/ignite/internal/network/handshake/ChannelAlreadyExistsException.java
=>
client/src/main/java/org/apache/ignite/internal/client/compute/SubmitResult.java}
(57%)
copy
modules/{cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/commands
=>
network/src/main/java/org/apache/ignite/internal/network/message}/ClusterNodeMessage.java
(76%)
copy
modules/{configuration-api/src/main/java/org/apache/ignite/configuration/notifications/ConfigurationListener.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/LowWatermarkChangedListener.java}
(68%)
