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) {