Skip to content

Commit

Permalink
[fix] Fix error like:
Browse files Browse the repository at this point in the history
Caused by: org.apache.http.ProtocolException: Transfer-encoding header already present
	at org.apache.http.protocol.RequestContent.process(RequestContent.java:93) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.protocol.ImmutableHttpProcessor.process(ImmutableHttpProcessor.java:132) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:182) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at org.apache.doris.flink.sink.writer.DorisStreamLoad.lambda$startLoad$0(DorisStreamLoad.java:347) ~[xxx-cdh-flink1-20-0-sql-gitlab-runner-1.0.0.jar:?]
	at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_232]
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_232]
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_232]
	... 1 more
  • Loading branch information
awol2005ex committed Dec 27, 2024
1 parent 911b959 commit 33af735
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,8 @@ protected boolean isRedirectable(String method) {
.setConnectTimeout(connectTimeout)
.setConnectionRequestTimeout(connectTimeout)
.build())
.addInterceptorLast(new RequestContent(true));;
.addInterceptorLast(new RequestContent(true));
;
}

/**
Expand Down

0 comments on commit 33af735

Please sign in to comment.