(ignite-3) branch IGNITE-26418 updated: Add degub logs

[mpochatkin]

This is an automated email from the ASF dual-hosted git repository.

mpochatkin pushed a commit to branch IGNITE-26418
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/IGNITE-26418 by this push:
     new 57ace50c6cd Add degub logs
57ace50c6cd is described below

commit 57ace50c6cd126a639a5008bfb55877fce47bfe4
Author: Pochatkin Mikhail <m.a.pochat...@gmail.com>
AuthorDate: Tue Oct 7 11:06:40 2025 +0300

    Add degub logs
---
 .../rest/deployment/CompletedFileUploadSubscriber.java       | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git 
a/modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/CompletedFileUploadSubscriber.java
 
b/modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/CompletedFileUploadSubscriber.java
index daa82a8eb01..eca5a05c2ca 100644
--- 
a/modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/CompletedFileUploadSubscriber.java
+++ 
b/modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/CompletedFileUploadSubscriber.java
@@ -19,6 +19,7 @@ package org.apache.ignite.internal.rest.deployment;
 
 import io.micronaut.http.multipart.CompletedFileUpload;
 import java.io.IOException;
+import java.io.InputStream;
 import java.util.concurrent.CompletableFuture;
 import org.apache.ignite.internal.deployunit.DeploymentUnit;
 import org.apache.ignite.internal.deployunit.tempstorage.TempStorage;
@@ -53,16 +54,22 @@ class CompletedFileUploadSubscriber implements 
Subscriber<CompletedFileUpload> {
 
     @Override
     public void onNext(CompletedFileUpload item) {
+        String filename = item.getFilename();
         try {
-            collector.addInputStream(item.getFilename(), 
item.getInputStream());
+            LOG.info("Receiving file: " + filename + ", size: " + 
item.getSize());
+            InputStream is = item.getInputStream();
+            LOG.info("Input stream obtained for file: " + filename + ", is: " 
+ is);
+            collector.addInputStream(filename, is);
+            LOG.info("File added to collector: " + filename);
         } catch (IOException e) {
-            LOG.error("Failed to read file: " + item.getFilename(), e);
+            LOG.error("Failed to read file: " + filename, e);
             suppressException(e);
         }
     }
 
     @Override
     public void onError(Throwable throwable) {
+        LOG.error("Subscriber failed: ", throwable);
         try {
             collector.rollback();
         } catch (Exception e) {
@@ -74,6 +81,7 @@ class CompletedFileUploadSubscriber implements 
Subscriber<CompletedFileUpload> {
 
     @Override
     public void onComplete() {
+        LOG.info("Subscriber completed");
         if (ex != null) {
             result.completeExceptionally(ex);
         } else {