We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent fe58714 commit 3aeadefCopy full SHA for 3aeadef
http/http-sink/src/main/java/com/dtstack/flink/sql/sink/http/DtHttpClient.java
@@ -118,7 +118,7 @@ public static void post(String httpUrl,
118
String contentEncoding) throws IOException {
119
HttpPost httpPost = new HttpPost(httpUrl);
120
httpPost.setConfig(requestConfig);
121
- StringEntity entity = new StringEntity(message);
+ StringEntity entity = new StringEntity(message, contentEncoding);
122
entity.setContentType(contentType);
123
entity.setContentEncoding(contentEncoding);
124
httpPost.setEntity(entity);
0 commit comments