siddharthteotia commented on code in PR #11710:
URL: https://github.com/apache/pinot/pull/11710#discussion_r1341664954
##########
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseBrokerRequestHandler.java:
##########
@@ -1654,6 +1669,24 @@ private long setQueryTimeout(String tableNameWithType,
Map<String, String> query
return remainingTimeMs;
}
+ /**
+ * Sets a query option indicating the maximum response size that can be sent
from a server to the broker. This size
+ * is measured for the serialized response.
+ */
+ private void setServerSerializedResponseLength(int numServers, @Nullable
BrokerRequest brokerRequest) {
+ if (brokerRequest == null) {
+ return;
+ }
+
+ Map<String, String> queryOptions =
brokerRequest.getPinotQuery().getQueryOptions();
+ Long maxLength =
QueryOptionsUtils.getMaxSerializedResponseLengthPerServer(queryOptions);
Review Comment:
Are we introducing this as a query option or instance config or both ?
--
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...@pinot.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
