This is an automated email from the ASF dual-hosted git repository.
yashmayya pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new f4c1cac8c1 Fix GET /queries broker API UnsupportedOperationException
bug (#15200)
f4c1cac8c1 is described below
commit f4c1cac8c11ea9c3cf35804a6f256bc57a63ec5a
Author: Yash Mayya <[email protected]>
AuthorDate: Wed Mar 5 21:30:40 2025 +0530
Fix GET /queries broker API UnsupportedOperationException bug (#15200)
---
.../pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java
index 03965b6fef..1dece755bb 100644
---
a/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java
+++
b/pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BrokerRequestHandlerDelegate.java
@@ -19,6 +19,7 @@
package org.apache.pinot.broker.requesthandler;
import com.fasterxml.jackson.databind.JsonNode;
+import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.Executor;
import javax.annotation.Nullable;
@@ -133,8 +134,8 @@ public class BrokerRequestHandlerDelegate implements
BrokerRequestHandler {
@Override
public Map<Long, String> getRunningQueries() {
- // Both engines share the same request Id generator, so the query will
have unique ids across the two engines.
- Map<Long, String> queries =
_singleStageBrokerRequestHandler.getRunningQueries();
+ // Both engines share the same request ID generator, so the query will
have unique IDs across the two engines.
+ Map<Long, String> queries = new
HashMap<>(_singleStageBrokerRequestHandler.getRunningQueries());
if (_multiStageBrokerRequestHandler != null) {
queries.putAll(_multiStageBrokerRequestHandler.getRunningQueries());
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
