From 6a3dc8aba9171a9a03ae45e1393f617e1d68d94d Mon Sep 17 00:00:00 2001 From: Dongyang Li Date: Wed, 11 Jun 2025 11:24:24 +0800 Subject: [PATCH] Revert "[regression-test](fix) fix StreamLoadAction bug (#51461)" This reverts commit 6e2f2eee2218327b9a3f7aade14c0adfad2137b5. --- .../apache/doris/regression/action/StreamLoadAction.groovy | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) 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 f8748433c214eb..c3a530b579c249 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,10 +216,7 @@ class StreamLoadAction implements SuiteAction { throw new IllegalStateException("Get http stream failed, status code is ${code}, body:\n${streamBody}") } - ByteArrayOutputStream buffer = new ByteArrayOutputStream(); - resp.getEntity().writeTo(buffer); // 完整读取数据 - log.info("entity new size is ${buffer.size()}") - return new ByteArrayInputStream(buffer.toByteArray()); + return resp.getEntity().getContent() } private RequestBuilder prepareRequestHeader(RequestBuilder requestBuilder) {