Skip to content

Commit 4429b94

Browse files
Chaho12Jaeho Yoo
authored andcommitted
Update ProxyRequestHandler.java
1 parent bd60529 commit 4429b94

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

gateway-ha/src/main/java/io/trino/gateway/proxyserver/ProxyRequestHandler.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -294,18 +294,18 @@ private ProxyResponse recordBackendForQueryId(Request request, ProxyResponse res
294294

295295
if (response.statusCode() == OK.getStatusCode()) {
296296
try {
297-
HashMap<String, String> results = OBJECT_MAPPER.readValue(response.body(), HashMap.class);
297+
HashMap<String, String> results = OBJECT_MAPPER.readValue(response.getDecompressedBody(), HashMap.class);
298298
queryDetail.setQueryId(results.get("id"));
299299
routingManager.setBackendForQueryId(queryDetail.getQueryId(), queryDetail.getBackendUrl());
300300
routingManager.setRoutingGroupForQueryId(queryDetail.getQueryId(), routingDestination.routingGroup());
301301
log.debug("QueryId [%s] mapped with proxy [%s]", queryDetail.getQueryId(), queryDetail.getBackendUrl());
302302
}
303303
catch (IOException e) {
304-
log.error("Failed to get QueryId from response [%s] , Status code [%s]", response.body(), response.statusCode());
304+
log.error("Failed to get QueryId from response [%s] , Status code [%s]", response.getDecompressedBody(), response.statusCode());
305305
}
306306
}
307307
else {
308-
log.error("Non OK HTTP Status code with response [%s] , Status code [%s], user: [%s]", response.body(), response.statusCode(), username.orElse(null));
308+
log.error("Non OK HTTP Status code with response [%s] , Status code [%s], user: [%s]", response.getDecompressedBody(), response.statusCode(), username.orElse(null));
309309
}
310310
queryDetail.setRoutingGroup(routingDestination.routingGroup());
311311
queryDetail.setExternalUrl(routingDestination.externalUrl());

0 commit comments

Comments
 (0)