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 7b6da4eabd IGNITE-21012 Fix typo in the transaction state COMMITED
(#2942)
add 38fa67e608 IGNITE-20845 Compute jobs cancellation (#2924)
No new revisions were added by this update.
Summary of changes:
.../compute/{ComputeJob.java => JobExecution.java} | 26 +++-
.../apache/ignite/compute/JobExecutionContext.java | 7 +
modules/compute/build.gradle | 1 +
.../ignite/internal/compute/ComputeComponent.java | 4 +-
.../internal/compute/ComputeComponentImpl.java | 4 +-
.../ignite/internal/compute/ComputeUtils.java | 2 +-
.../internal/compute/JobExecutionContextImpl.java | 11 +-
.../internal/compute/executor/ComputeExecutor.java | 4 +-
.../compute/executor/ComputeExecutorImpl.java | 18 ++-
.../compute/executor/JobExecutionImpl.java | 62 +++++++++
.../compute/executor/QueueExecutionImpl.java | 88 ++++++++++++
.../compute/queue/PriorityQueueExecutor.java | 33 +++--
.../ignite/internal/compute/queue/QueueEntry.java | 52 ++++++-
.../internal/compute/queue/QueueExecution.java} | 28 ++--
.../compute/JobExecutionContextImplTest.java | 16 ++-
.../compute/executor/ComputeExecutorTest.java | 110 +++++++++++++++
.../compute/queue/PriorityQueueExecutorTest.java | 154 +++++++++++++++++----
17 files changed, 551 insertions(+), 69 deletions(-)
copy modules/api/src/main/java/org/apache/ignite/compute/{ComputeJob.java =>
JobExecution.java} (62%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/executor/JobExecutionImpl.java
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/executor/QueueExecutionImpl.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncCloseable.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/queue/QueueExecution.java}
(61%)
create mode 100644
modules/compute/src/test/java/org/apache/ignite/internal/compute/executor/ComputeExecutorTest.java
