This is an automated email from the ASF dual-hosted git repository.
apkhmv pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from a92d1a54f53 IGNITE-26229 Fix wrong default profile size usage in
"aipersist" (#6443)
add a86b59014cb IGNITE-26116 Create compute task events for remote
execution (#6391)
No new revisions were added by this update.
Summary of changes:
.../client/proto/ClientComputeJobUnpacker.java | 12 ++
.../internal/client/proto/ClientMessagePacker.java | 13 ++
.../client/proto/ClientMessageUnpacker.java | 11 ++
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../ignite/client/handler/ItClientHandlerTest.java | 1 +
.../ignite/client/handler/ClientHandlerModule.java | 1 +
.../ClientComputeExecuteColocatedRequest.java | 11 +-
.../ClientComputeExecutePartitionedRequest.java | 17 +-
.../compute/ClientComputeExecuteRequest.java | 17 +-
.../ignite/internal/client/TcpClientChannel.java | 1 +
.../internal/client/compute/ClientCompute.java | 31 +++-
.../apache/ignite/client/fakes/FakeCompute.java | 7 +-
.../internal/compute/events/EventMatcher.java | 34 +++-
.../compute/events/ItComputeEventsTest.java | 206 ++++++++++++++++-----
.../events/ItThinClientComputeEventsTest.java | 4 +-
.../ignite/internal/compute/ComputeComponent.java | 26 +--
.../internal/compute/ComputeComponentImpl.java | 31 ++--
.../internal/compute/ComputeJobFailover.java | 64 ++++---
.../internal/compute/ComputeMessageTypes.java | 5 +
.../internal/compute/FailSafeJobExecution.java | 5 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 53 ++++--
.../internal/compute/IgniteComputeInternal.java | 8 +-
.../apache/ignite/internal/compute/JobStarter.java | 3 +
.../internal/compute/RemoteExecutionContext.java | 11 +-
.../compute/events/ComputeEventMetadata.java | 159 ++++------------
.../events/ComputeEventMetadataBuilder.java | 107 +++++++++++
.../compute/events/ComputeEventsFactory.java | 21 ++-
.../internal/compute/executor/ComputeExecutor.java | 4 +-
.../compute/executor/ComputeExecutorImpl.java | 4 +-
...obStatesResponse.java => ExecuteRequestV2.java} | 24 +--
.../compute/messaging/ComputeMessaging.java | 18 +-
.../compute/queue/PriorityQueueExecutor.java | 11 +-
.../internal/compute/ComputeComponentImplTest.java | 11 +-
.../internal/compute/IgniteComputeImplTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 1 +
35 files changed, 629 insertions(+), 314 deletions(-)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/events/ComputeEventMetadataBuilder.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/message/{JobStatesResponse.java
=> ExecuteRequestV2.java} (63%)
