Pochatkin commented on code in PR #2044:
URL: https://github.com/apache/ignite-3/pull/2044#discussion_r1197557237
##########
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentManagerImpl.java:
##########
@@ -176,17 +143,53 @@ public CompletableFuture<Boolean> deployAsync(String id,
Version version, boolea
});
}
+ private CompletableFuture<Boolean> doDeploy(String id, Version version,
DeploymentUnit deploymentUnit) {
+ Map<String, byte[]> unitContent;
+ try {
+ unitContent = deploymentUnit.content().entrySet().stream()
+ .collect(Collectors.toMap(Map.Entry::getKey, entry ->
readContent(entry.getValue())));
+ } catch (DeploymentUnitReadException e) {
+ return failedFuture(e);
+ }
+ return tracker.track(id, version, deployer.deploy(id,
version.render(), unitContent)
+ .thenCompose(deployed -> {
Review Comment:
I didn't understand your question. First of all we deploy file to local
node, after that if deploy was success we create node status with DEPLOYED
status and after that if status created successfully we start deploy to cmg
node.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
