From d32d6f503204ee68d4fbbc8091646221d7530677 Mon Sep 17 00:00:00 2001
From: OZGCloud <ozgcloud@mgm-tp.com>
Date: Tue, 21 Nov 2023 08:07:52 +0100
Subject: [PATCH] reduce chunk size
---
.../kop/common/binaryfile/BinaryFileUploadStreamObserver.java | 1 +
.../de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java | 2 +-
2 files changed, 2 insertions(+), 1 deletion(-)
diff --git a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/BinaryFileUploadStreamObserver.java b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/BinaryFileUploadStreamObserver.java
index ae9c6ad..c9749d8 100644
--- a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/BinaryFileUploadStreamObserver.java
+++ b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/BinaryFileUploadStreamObserver.java
@@ -58,6 +58,7 @@ public class BinaryFileUploadStreamObserver<ReqT, R> implements ClientResponseOb
@Override
public void onError(Throwable t) {
+ LOG.error("Error on uploading file. Completing Future.", t);
future.completeExceptionally(t);
}
diff --git a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
index 7554b3e..c9dc311 100644
--- a/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
+++ b/kop-common-lib/src/main/java/de/itvsh/kop/common/binaryfile/GrpcFileUploadUtils.java
@@ -48,7 +48,7 @@ import lombok.extern.log4j.Log4j2;
@NoArgsConstructor(access = AccessLevel.PRIVATE)
public class GrpcFileUploadUtils {
- static final int CHUNK_SIZE = 255 * 1024;
+ static final int CHUNK_SIZE = 4 * 1024;
/*
* Q = Request Type; S = Response Type
--
GitLab