This is an automated email from the ASF dual-hosted git repository. shauryachats pushed a commit to branch pr_18172 in repository https://gitbox.apache.org/repos/asf/pinot.git
commit 8754bf240da81ad967b8c7bb6cd863631545303e Author: shauryachats <[email protected]> AuthorDate: Wed Apr 29 01:48:42 2026 +0000 Added improvements --- .../org/apache/pinot/broker/api/resources/PinotBrokerDebug.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pinot-broker/src/main/java/org/apache/pinot/broker/api/resources/PinotBrokerDebug.java b/pinot-broker/src/main/java/org/apache/pinot/broker/api/resources/PinotBrokerDebug.java index 71c30c9a52a..c53a8bf93e6 100644 --- a/pinot-broker/src/main/java/org/apache/pinot/broker/api/resources/PinotBrokerDebug.java +++ b/pinot-broker/src/main/java/org/apache/pinot/broker/api/resources/PinotBrokerDebug.java @@ -147,6 +147,7 @@ public class PinotBrokerDebug { @ApiOperation(value = "Get the routing table for a table") @ApiResponses(value = { @ApiResponse(code = 200, message = "Routing table"), + @ApiResponse(code = 400, message = "Bad request"), @ApiResponse(code = 404, message = "Routing not found"), @ApiResponse(code = 500, message = "Internal server error") }) @@ -179,6 +180,7 @@ public class PinotBrokerDebug { @ApiOperation(value = "Get the routing table for a table, including optional segments") @ApiResponses(value = { @ApiResponse(code = 200, message = "Routing table"), + @ApiResponse(code = 400, message = "Bad request"), @ApiResponse(code = 404, message = "Routing not found"), @ApiResponse(code = 500, message = "Internal server error") }) @@ -218,9 +220,11 @@ public class PinotBrokerDebug { throw new WebApplicationException("Logical table config not found for: " + rawTableName, Response.Status.NOT_FOUND); } + // Use a single requestId across all physical tables so replica-group selection is consistent. + long requestId = getRequestId(); for (String physicalTableWithType : config.getPhysicalTableConfigMap().keySet()) { RoutingTable routingTable = routingManager.getRoutingTable( - CalciteSqlCompiler.compileToBrokerRequest("SELECT * FROM " + physicalTableWithType), getRequestId()); + CalciteSqlCompiler.compileToBrokerRequest("SELECT * FROM " + physicalTableWithType), requestId); if (routingTable != null) { consumer.accept(physicalTableWithType, routingTable); } else { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
