diff options
| author | lijinyang <[email protected]> | 2023-11-16 10:26:20 +0800 |
|---|---|---|
| committer | lijinyang <[email protected]> | 2023-11-16 10:26:20 +0800 |
| commit | 9250c02a4be3a252628393f205f9f82765af8ba7 (patch) | |
| tree | 85f0edf8c1c7f9bfd0a9e07e86ad14b35f3b89df | |
| parent | d22f7b5e027a77bca829dc8b823c64b93f8ed85d (diff) | |
fix:查询网关result_id格式修改23.11.16
| -rw-r--r-- | docs/release/release-23-11.md | 4 | ||||
| -rw-r--r-- | src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java | 4 |
2 files changed, 6 insertions, 2 deletions
diff --git a/docs/release/release-23-11.md b/docs/release/release-23-11.md new file mode 100644 index 0000000..d382ee6 --- /dev/null +++ b/docs/release/release-23-11.md @@ -0,0 +1,4 @@ +Release 23.11 +* 升级JDK至JDK11(GAL-429) +* 更换新版查询网关url +* 优化log日志信息
\ No newline at end of file diff --git a/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java b/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java index 7289412..b4ac737 100644 --- a/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java +++ b/src/main/java/com/mesa/reportservice/service/impl/ClickhouseServiceImpl.java @@ -52,7 +52,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { CloseableHttpResponse response = null; String query_id = ""; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/v1/sql/query/query_id?resultId=" + resultId + "&query="); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/v1/sql/query/query_id?result_id=" + resultId + "&query="); String sql = null; sql = URLEncoder.encode(query, "utf8").replaceAll("\\+", "%20"); url = url + sql; @@ -91,7 +91,7 @@ public class ClickhouseServiceImpl implements ClickhouseService { // 发起请求 HttpResult rs = null; try { - String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sql?option=long-term&resultId=" + resultId + "&query="); + String url = URLUtil.normalize(clickhouseConfig.getGateway_ip().trim() + "/sql?option=long-term&result_id=" + resultId + "&query="); query = URLEncoder.encode(query, "utf8").replaceAll("\\+", "%20"); String jobsql = url + query; HttpGet httpGet = new HttpGet(jobsql); |