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.
2 parents fe58714 + 3aeadef commit e5a7ccdCopy full SHA for e5a7ccd
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