klsince commented on code in PR #9171:
URL: https://github.com/apache/pinot/pull/9171#discussion_r947283582
##########
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java:
##########
@@ -85,4 +87,22 @@ public BrokerResponse handleRequest(JsonNode request,
@Nullable RequesterIdentit
}
return _singleStageBrokerRequestHandler.handleRequest(request,
requesterIdentity, requestContext);
}
+
+ @Override
+ public Map<Long, String> getRunningQueries() {
+ if (_multiStageWorkerRequestHandler != null) {
+ return _multiStageWorkerRequestHandler.getRunningQueries();
Review Comment:
ic... good to know.
##########
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java:
##########
@@ -85,4 +87,22 @@ public BrokerResponse handleRequest(JsonNode request,
@Nullable RequesterIdentit
}
return _singleStageBrokerRequestHandler.handleRequest(request,
requesterIdentity, requestContext);
}
+
+ @Override
+ public Map<Long, String> getRunningQueries() {
+ if (_multiStageWorkerRequestHandler != null) {
+ return _multiStageWorkerRequestHandler.getRunningQueries();
+ }
+ return _singleStageBrokerRequestHandler.getRunningQueries();
+ }
+
+ @Override
+ public boolean cancelQuery(long queryId, int timeoutMs, Executor executor,
HttpConnectionManager connMgr,
+ Map<String, Integer> serverResponses)
+ throws Exception {
+ if (_multiStageWorkerRequestHandler != null) {
+ return _multiStageWorkerRequestHandler.cancelQuery(queryId, timeoutMs,
executor, connMgr, serverResponses);
Review Comment:
will add the TODO.
--
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
