From 872262a80f0426a947639bca36b6af81e1f6b3ca Mon Sep 17 00:00:00 2001 From: shuke987 Date: Tue, 3 Jun 2025 21:37:56 +0800 Subject: [PATCH 1/2] [regression-test](fix) fix StreamLoadAction bug --- .../apache/doris/regression/action/StreamLoadAction.groovy | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy index c3a530b579c249..a5041bc2263f41 100644 --- a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy +++ b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy @@ -216,7 +216,9 @@ class StreamLoadAction implements SuiteAction { throw new IllegalStateException("Get http stream failed, status code is ${code}, body:\n${streamBody}") } - return resp.getEntity().getContent() + ByteArrayOutputStream buffer = new ByteArrayOutputStream(); + resp.getEntity().writeTo(buffer); // 完整读取数据 + return new ByteArrayInputStream(buffer.toByteArray()); } private RequestBuilder prepareRequestHeader(RequestBuilder requestBuilder) { From 6dde17992cc1bb0f1b1ed98cddcb7ae1c977b93d Mon Sep 17 00:00:00 2001 From: shuke987 Date: Wed, 4 Jun 2025 14:14:38 +0800 Subject: [PATCH 2/2] 2 --- .../org/apache/doris/regression/action/StreamLoadAction.groovy | 1 + 1 file changed, 1 insertion(+) diff --git a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy index a5041bc2263f41..f8748433c214eb 100644 --- a/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy +++ b/regression-test/framework/src/main/groovy/org/apache/doris/regression/action/StreamLoadAction.groovy @@ -218,6 +218,7 @@ class StreamLoadAction implements SuiteAction { ByteArrayOutputStream buffer = new ByteArrayOutputStream(); resp.getEntity().writeTo(buffer); // 完整读取数据 + log.info("entity new size is ${buffer.size()}") return new ByteArrayInputStream(buffer.toByteArray()); }