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 938d43340a IGNITE-23801 Hocon configuration source should use
synthetic key value in logs (#4806)
add f3d533da8e IGNITE-23338 Reduce number of intermediate serializations
in Compute (#4778)
No new revisions were added by this update.
Summary of changes:
.../client/proto/ClientComputeJobPacker.java | 28 +++--
.../client/proto/ClientComputeJobUnpacker.java | 37 ++++---
.../proto/ClientComputeJobPackerUnpackerTest.java | 30 ++++++
.../client/proto/pojo/PojoConverterTest.java | 5 +-
.../apache/ignite/client/fakes/FakeCompute.java | 10 ++
.../ignite/internal/compute/ComputeUtils.java | 116 ++++++++++++++++++++-
.../internal/compute/DelegatingJobExecution.java | 9 ++
.../ignite/internal/compute/ExecutionManager.java | 10 +-
.../internal/compute/FailSafeJobExecution.java | 6 ++
.../internal/compute/JobExecutionWrapper.java | 5 +
.../internal/compute/MarshallerProvider.java | 8 +-
.../compute/ResultMarshallingJobExecution.java | 65 ------------
.../internal/compute/TaskExecutionWrapper.java | 5 +
.../compute/executor/ComputeExecutorImpl.java | 7 +-
.../compute/executor/JobExecutionInternal.java | 17 ++-
.../compute/task/DelegatingTaskExecution.java | 7 ++
.../compute/task/TaskExecutionInternal.java | 6 ++
.../internal/compute/ComputeJobDataHolder.java | 60 +++++++++++
.../internal/compute/ComputeJobDataType.java} | 35 +++++--
.../internal/compute}/PojoConversionException.java | 2 +-
.../ignite/internal/compute}/PojoConverter.java | 2 +-
.../apache/ignite/internal/runner/app/Jobs.java | 31 +++++-
.../client/ItThinClientComputeMarshallingTest.java | 67 ++++++++++--
.../app/compute/ItEmbeddedMarshallingTest.java | 18 ++++
24 files changed, 467 insertions(+), 119 deletions(-)
delete mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/ResultMarshallingJobExecution.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/compute/ComputeJobDataHolder.java
rename
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/ComputeJobType.java
=>
core/src/main/java/org/apache/ignite/internal/compute/ComputeJobDataType.java}
(59%)
rename
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/pojo
=>
core/src/main/java/org/apache/ignite/internal/compute}/PojoConversionException.java
(95%)
rename
modules/{client-common/src/main/java/org/apache/ignite/internal/client/proto/pojo
=> core/src/main/java/org/apache/ignite/internal/compute}/PojoConverter.java
(99%)
