grainlin commented on issue #492:
URL:
https://github.com/apache/doris-flink-connector/issues/492#issuecomment-2373565653
org.apache.doris.flink.sink.schema.SchemaChangeManager
private String charsetEncoding = "UTF-8";
public HttpPost buildHttpPost(String ddl, String database) throws
IllegalArgumentException, IOException {
Map<String, String> param = new HashMap<>();
param.put("stmt", ddl);
String requestUrl =
String.format("http://%s/api/query/default_cluster/%s";, new Object[] {
RestService.randomEndpoint(this.dorisOptions.getFenodes(), LOG), database });
HttpPost httpPost = new HttpPost(requestUrl);
httpPost.setHeader("Authorization", authHeader());
httpPost.setHeader("Content-Type",
String.format("application/json;charset=%s", new Object[] {
this.charsetEncoding }));
httpPost.setEntity((HttpEntity)new StringEntity(this.objectMapper
.writeValueAsString(param), this.charsetEncoding));
return httpPost;
}
don't know why charset Assignment failed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
