shauryachats commented on code in PR #17145:
URL: https://github.com/apache/pinot/pull/17145#discussion_r2566184749
##########
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/MultiStageBrokerRequestHandler.java:
##########
@@ -426,7 +430,8 @@ private ImmutableQueryEnvironment.Config
getQueryEnvConf(HttpHeaders httpHeaders
.requestId(requestId)
.database(database)
.tableCache(_tableCache)
- .workerManager(_workerManager)
+ .workerManager(new WorkerManager(_brokerId, _hostname, _port,
Review Comment:
Delegated getting the correct RoutingManager to
`CrossClusterFederationProvider` and instead of initing a new workerManager,
created two workerManagers: regular and federated and selecting the correct one
based on query options.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
