kangkaisen commented on issue #549: Add a colocate join meta repair tool URL: https://github.com/apache/incubator-doris/issues/549#issuecomment-455975626 for java Http client ``` Request request = asyncHttpClient.preparePut(url).setBody(content) .setHeader("Expect", "100-continue") .setHeader("Authorization", basicAuthHeader()) .setFollowRedirect(true) .build(); Response response = asyncHttpClient.executeRequest(request).get(); ``` the code will run into `MessageAggregator`. `decode`: ``` // Merge the received chunk into the content of the current message. CompositeByteBuf content = (CompositeByteBuf) currentMessage.content(); ``` which is normal. but for curl client, the code will not run into above line and will finally run into `ByteToMessageDecoder` ``` /** * Called when the input of the channel was closed which may be because it changed to inactive or because of * {@link ChannelInputShutdownEvent}. */ void channelInputClosed(ChannelHandlerContext ctx, List<Object> out) throws Exception { if (cumulation != null) { callDecode(ctx, cumulation, out); decodeLast(ctx, cumulation, out); } else { decodeLast(ctx, Unpooled.EMPTY_BUFFER, out); } } ``` so the curl client will get a error.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services --------------------------------------------------------------------- To unsubscribe, e-mail: dev-unsubscr...@doris.apache.org For additional commands, e-mail: dev-h...@doris.apache.org
