(pinot) branch master updated (1fc303d9f6 -> 50a32c28f7)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from 1fc303d9f6 Pull some dependencies to root POM (#13781) add 50a32c28f7 Remove usage of the deprecated replicaPerPar

Re: [PR] Remove usage of the deprecated replicaPerPartition. [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13671: URL: https://github.com/apache/pinot/pull/13671 -- 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

[PR] Fix filtered aggregate with ordering [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang opened a new pull request, #13784: URL: https://github.com/apache/pinot/pull/13784 Fix #13749 For filtered aggregate group-by queries, when there are mixed same aggregate with and without filter, and the ordering is applied to the aggregate without filter, we might get

Re: [I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
lnbest0707-uber commented on issue #13780: URL: https://github.com/apache/pinot/issues/13780#issuecomment-227706 Add a [design doc](https://docs.google.com/document/d/1Er2Tmtl5Pgwdapn5iOJ5qlCDU_2P67YMdpdsmL36MCk/edit?usp=sharing) -- This is an automated message from the Apache Git S

Re: [I] Using SIMD for dealing with json at speed [pinot]

2024-08-08 Thread via GitHub
abhioncbr commented on issue #13773: URL: https://github.com/apache/pinot/issues/13773#issuecomment-2276986306 @hpvd, what would you suggest, using the simdjson library for all JSON data handling or something else? -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] Support madvise for MmapMemory [pinot]

2024-08-08 Thread via GitHub
jasperjiaguo commented on PR #13721: URL: https://github.com/apache/pinot/pull/13721#issuecomment-2276970883 >But we can't change the default without a wide spectrum of consequences and I'd discourage that. Though it's obviously good to have this feature and make it configurable. Yes

Re: [PR] Remove ingestion metrics when consuming segment relocates [pinot]

2024-08-08 Thread via GitHub
sajjad-moradi commented on code in PR #13668: URL: https://github.com/apache/pinot/pull/13668#discussion_r1710442034 ## pinot-core/src/main/java/org/apache/pinot/core/data/manager/realtime/IngestionDelayTracker.java: ## @@ -214,7 +230,7 @@ private long getPartitionOffsetLag(Inge

svn commit: r70760 - /dev/pinot/apache-pinot-1.2.0-rc1/

2024-08-08 Thread ankitsultana
Author: ankitsultana Date: Thu Aug 8 23:33:25 2024 New Revision: 70760 Log: Update apache-pinot-1.2.0-rc1 Added: dev/pinot/apache-pinot-1.2.0-rc1/ dev/pinot/apache-pinot-1.2.0-rc1/apache-pinot-1.2.0-bin.tar.gz (with props) dev/pinot/apache-pinot-1.2.0-rc1/apache-pinot-1.2.0-bin.ta

(pinot) branch release-1.2.0-rc updated: [maven-release-plugin] prepare for next development iteration

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a commit to branch release-1.2.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git The following commit(s) were added to refs/heads/release-1.2.0-rc by this push: new 34ab49d1aa [maven-relea

(pinot) annotated tag release-1.2.0-rc1 updated (60899d7b8e -> 99d360e73d)

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a change to annotated tag release-1.2.0-rc1 in repository https://gitbox.apache.org/repos/asf/pinot.git *** WARNING: tag release-1.2.0-rc1 was modified! *** from 60899d7b8e (commit) to 99d360e73d (

(pinot) branch release-1.2.0-rc updated: [maven-release-plugin] prepare release release-1.2.0-rc1

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a commit to branch release-1.2.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git The following commit(s) were added to refs/heads/release-1.2.0-rc by this push: new 60899d7b8e [maven-relea

(pinot) branch master updated (a9aad2de86 -> 1fc303d9f6)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from a9aad2de86 add routing policy in query errmsg upon unavailable segments for a bit more context (#13706) add 1fc30

Re: [PR] Pull some dependencies to root POM [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13781: URL: https://github.com/apache/pinot/pull/13781 -- 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

(pinot) branch master updated: add routing policy in query errmsg upon unavailable segments for a bit more context (#13706)

2024-08-08 Thread xbli
This is an automated email from the ASF dual-hosted git repository. xbli 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 a9aad2de86 add routing policy in query errmsg upon

Re: [PR] add routing policy in query errmsg upon unavailable segments for a bit more context [pinot]

2024-08-08 Thread via GitHub
klsince merged PR #13706: URL: https://github.com/apache/pinot/pull/13706 -- 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.apac

(pinot) branch release-1.2.0-rc updated (41d89a1b10 -> ad284a6d91)

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a change to branch release-1.2.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git discard 41d89a1b10 [maven-release-plugin] prepare for next development iteration omit 30c15985bd [maven-re

(pinot) 01/02: Add hadoop-client-runtime dependency to fix quickstart NoClassDefFoundError issue (#13548)

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a commit to branch release-1.2.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git commit 81cf64f26aa412781c7b77be8107ae60795978f5 Author: Yash Mayya AuthorDate: Mon Jul 8 20:21:25 2024 +0530

(pinot) 02/02: Minor LICENSE-binary Correction for 1.2.0 Release (#13783)

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a commit to branch release-1.2.0-rc in repository https://gitbox.apache.org/repos/asf/pinot.git commit ad284a6d91036152139d7aacb463aed28653aa57 Author: Ankit Sultana AuthorDate: Thu Aug 8 16:30:07 2024 -0500

(pinot) branch master updated (4a1963437d -> d5c4f1c4fe)

2024-08-08 Thread ankitsultana
This is an automated email from the ASF dual-hosted git repository. ankitsultana pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from 4a1963437d Bump software.amazon.awssdk:bom from 2.26.31 to 2.27.0 (#13779) add d5c4f1c4fe Minor LICENSE-bin

Re: [PR] Minor LICENSE-binary Corrections for 1.2.0 Release [pinot]

2024-08-08 Thread via GitHub
ankitsultana merged PR #13783: URL: https://github.com/apache/pinot/pull/13783 -- 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

Re: [PR] add routing policy in query errmsg upon unavailable segments for a bit more context [pinot]

2024-08-08 Thread via GitHub
klsince commented on code in PR #13706: URL: https://github.com/apache/pinot/pull/13706#discussion_r1710316668 ## pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseSingleStageBrokerRequestHandler.java: ## @@ -836,6 +840,31 @@ protected BrokerResponse handleRe

Re: [I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
mcvsubbu commented on issue #13780: URL: https://github.com/apache/pinot/issues/13780#issuecomment-2276661932 At a high level, we could treat each topic-partition pair as a single consuming partition in pinot. We will need some more abstractions to be able to support different encodi

Re: [I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
lnbest0707-uber commented on issue #13780: URL: https://github.com/apache/pinot/issues/13780#issuecomment-2276660249 > +100 on this.. it's coming up multiple times. > > Do you have any initial thoughts? I've already had a working prototyping, would contribute soon. -- This is

Re: [I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
kishoreg commented on issue #13780: URL: https://github.com/apache/pinot/issues/13780#issuecomment-2276652075 +100 on this.. it's coming up multiple times. Do you have any initial thoughts? -- This is an automated message from the Apache Git Service. To respond to the message, pleas

Re: [PR] add metadata ttl field to DedupConfig [pinot]

2024-08-08 Thread via GitHub
klsince commented on code in PR #13636: URL: https://github.com/apache/pinot/pull/13636#discussion_r1710225780 ## pinot-segment-local/src/main/java/org/apache/pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java: ## @@ -0,0 +1,104 @@ +/** + * Licensed to the Apache S

Re: [I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
mcvsubbu commented on issue #13780: URL: https://github.com/apache/pinot/issues/13780#issuecomment-2276628592 Duplicate of https://github.com/apache/pinot/issues/8806 ? Duplicate of https://github.com/apache/pinot/issues/5647 (as you mention in description) -- This is an automated mess

Re: [PR] [Feature] Add the ability to compress and decompress tar archive file with ZStandard and LZ4 compressors [pinot]

2024-08-08 Thread via GitHub
codecov-commenter commented on PR #13782: URL: https://github.com/apache/pinot/pull/13782#issuecomment-2276615307 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/13782?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&u

[PR] Minor LICENSE-binary Corrects for 1.2.0 Release [pinot]

2024-08-08 Thread via GitHub
ankitsultana opened a new pull request, #13783: URL: https://github.com/apache/pinot/pull/13783 I was re-doing the license/notice steps after cherry-picking #13548 and found that there were minor errors. No changes to notice file. -- This is an automated message from the Apache Git

Re: [PR] Pull some dependencies to root POM [pinot]

2024-08-08 Thread via GitHub
codecov-commenter commented on PR #13781: URL: https://github.com/apache/pinot/pull/13781#issuecomment-2276563550 ## [Codecov](https://app.codecov.io/gh/apache/pinot/pull/13781?dropdown=coverage&src=pr&el=h1&utm_medium=referral&utm_source=github&utm_content=comment&utm_campaign=pr+comments&u

Re: [PR] Add more unit test for `AbstractMetricsTest` [pinot]

2024-08-08 Thread via GitHub
dttung2905 commented on code in PR #13697: URL: https://github.com/apache/pinot/pull/13697#discussion_r1710196740 ## pinot-common/src/test/java/org/apache/pinot/common/metrics/AbstractMetricsTest.java: ## @@ -48,4 +52,66 @@ public void testAddOrUpdateGauge() { controllerMet

Re: [PR] Add more unit test for `AbstractMetricsTest` [pinot]

2024-08-08 Thread via GitHub
dttung2905 commented on code in PR #13697: URL: https://github.com/apache/pinot/pull/13697#discussion_r1710195309 ## pinot-common/src/test/java/org/apache/pinot/common/metrics/AbstractMetricsTest.java: ## @@ -48,4 +52,66 @@ public void testAddOrUpdateGauge() { controllerMet

[PR] [Feature] Add the ability to compress and decompress tar archive file with ZStandard and LZ4 compressors [pinot]

2024-08-08 Thread via GitHub
jackluo923 opened a new pull request, #13782: URL: https://github.com/apache/pinot/pull/13782 This pull request enhances tar archive compression and decompression by adding support for ZStandard and LZ4, alongside GZip. The code is refactored for easy extensibility, allowing new compressors

Re: [PR] Ensure upsert deletion consistency when enabled with compaction flow [pinot]

2024-08-08 Thread via GitHub
tibrewalpratik17 commented on code in PR #13347: URL: https://github.com/apache/pinot/pull/13347#discussion_r1710012624 ## pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/ConcurrentMapTableUpsertMetadataManagerForConsistentDeletes.java: ## @@ -0,0 +1,75 @

[PR] Pull some dependencies to root POM [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang opened a new pull request, #13781: URL: https://github.com/apache/pinot/pull/13781 The following dependencies are pulled up to be managed in root POM: - com.google.re2j:re2j - org.midrot:jbcrypt - com.yammer.metrics:metrics-core - com.thoughtworks.paranamer:paranamer

(pinot) branch dependabot/maven/io.grpc-grpc-bom-1.66.0 deleted (was f7a17a3230)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch dependabot/maven/io.grpc-grpc-bom-1.66.0 in repository https://gitbox.apache.org/repos/asf/pinot.git was f7a17a3230 Bump io.grpc:grpc-bom from 1.65.1 to 1.66.0 The revisions that were on th

[I] Multiple upstream source ingestion support on Pinot [pinot]

2024-08-08 Thread via GitHub
lnbest0707-uber opened a new issue, #13780: URL: https://github.com/apache/pinot/issues/13780 Pinot nowadays only supports realtime table ingested from one single source stream, e.g. one Kafka topic from a Kafka cluster. And inside the table manager, the internal segment partition concept i

Re: [PR] Bump org.apache.commons:commons-lang3 from 3.15.0 to 3.16.0 [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13778: URL: https://github.com/apache/pinot/pull/13778 -- 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

(pinot) branch master updated (f8c8bc9881 -> 7071bf5338)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from f8c8bc9881 Bump io.grpc:grpc-bom from 1.65.1 to 1.66.0 (#13777) add 7071bf5338 Bump org.apache.commons:commons-lan

(pinot) branch master updated (7071bf5338 -> 4a1963437d)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from 7071bf5338 Bump org.apache.commons:commons-lang3 from 3.15.0 to 3.16.0 (#13778) add 4a1963437d Bump software.amaz

(pinot) branch dependabot/maven/software.amazon.awssdk-bom-2.27.0 deleted (was 2f03631330)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch dependabot/maven/software.amazon.awssdk-bom-2.27.0 in repository https://gitbox.apache.org/repos/asf/pinot.git was 2f03631330 Bump software.amazon.awssdk:bom from 2.26.31 to 2.27.0 The rev

Re: [PR] Bump software.amazon.awssdk:bom from 2.26.31 to 2.27.0 [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13779: URL: https://github.com/apache/pinot/pull/13779 -- 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

(pinot) branch master updated (d196994db9 -> d6a5597722)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from d196994db9 Bump Kafka from 2.8.1 to 2.8.2 (#13775) add d6a5597722 Pull testcontainers dependencies to root POM (#1

Re: [PR] Bump io.grpc:grpc-bom from 1.65.1 to 1.66.0 [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13777: URL: https://github.com/apache/pinot/pull/13777 -- 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

(pinot) branch master updated (d6a5597722 -> f8c8bc9881)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/pinot.git from d6a5597722 Pull testcontainers dependencies to root POM (#13774) add f8c8bc9881 Bump io.grpc:grpc-bom from 1.65.1

(pinot) branch dependabot/maven/org.apache.commons-commons-lang3-3.16.0 deleted (was 5b3b4dd55c)

2024-08-08 Thread jackie
This is an automated email from the ASF dual-hosted git repository. jackie pushed a change to branch dependabot/maven/org.apache.commons-commons-lang3-3.16.0 in repository https://gitbox.apache.org/repos/asf/pinot.git was 5b3b4dd55c Bump org.apache.commons:commons-lang3 from 3.15.0 to 3.16

Re: [PR] Pull testcontainers dependencies to root POM [pinot]

2024-08-08 Thread via GitHub
Jackie-Jiang merged PR #13774: URL: https://github.com/apache/pinot/pull/13774 -- 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

Re: [PR] UI Load time Improvement API Fixes #13278 [pinot]

2024-08-08 Thread via GitHub
deepthi912 commented on code in PR #13296: URL: https://github.com/apache/pinot/pull/13296#discussion_r1708168968 ## pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/PinotSegmentRestletResource.java: ## @@ -230,25 +231,54 @@ public List>> getSegments(

Re: [PR] Ensure upsert deletion consistency when enabled with compaction flow [pinot]

2024-08-08 Thread via GitHub
tibrewalpratik17 commented on code in PR #13347: URL: https://github.com/apache/pinot/pull/13347#discussion_r1710012624 ## pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/ConcurrentMapTableUpsertMetadataManagerForConsistentDeletes.java: ## @@ -0,0 +1,75 @

Re: [PR] Ensure upsert deletion consistency when enabled with compaction flow [pinot]

2024-08-08 Thread via GitHub
klsince commented on code in PR #13347: URL: https://github.com/apache/pinot/pull/13347#discussion_r1709966912 ## pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/ConcurrentMapTableUpsertMetadataManagerForConsistentDeletes.java: ## @@ -0,0 +1,75 @@ +/** +

svn commit: r70752 - /dev/pinot/apache-pinot-1.2.0-rc0/

2024-08-08 Thread ankitsultana
Author: ankitsultana Date: Thu Aug 8 15:18:21 2024 New Revision: 70752 Log: Delete release-1.2.0-rc0 Removed: dev/pinot/apache-pinot-1.2.0-rc0/ - To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional

Re: [PR] Optimize NullableSingleInputAggregationFunction when entire block is null [pinot]

2024-08-08 Thread via GitHub
yashmayya commented on PR #13758: URL: https://github.com/apache/pinot/pull/13758#issuecomment-2276020558 I've updated the mode aggregation benchmark and pushed the change to this branch itself. Here are the results: Without this optimization: ``` Benchmark

(pinot) branch dependabot/maven/software.amazon.awssdk-bom-2.27.0 created (now 2f03631330)

2024-08-08 Thread github-bot
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/software.amazon.awssdk-bom-2.27.0 in repository https://gitbox.apache.org/repos/asf/pinot.git at 2f03631330 Bump software.amazon.awssdk:bom from 2.26.31 to 2.27.0 No

[PR] Bump software.amazon.awssdk:bom from 2.26.31 to 2.27.0 [pinot]

2024-08-08 Thread via GitHub
dependabot[bot] opened a new pull request, #13779: URL: https://github.com/apache/pinot/pull/13779 Bumps software.amazon.awssdk:bom from 2.26.31 to 2.27.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=softwar

(pinot) branch dependabot/maven/io.grpc-grpc-bom-1.66.0 created (now f7a17a3230)

2024-08-08 Thread github-bot
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/io.grpc-grpc-bom-1.66.0 in repository https://gitbox.apache.org/repos/asf/pinot.git at f7a17a3230 Bump io.grpc:grpc-bom from 1.65.1 to 1.66.0 No new revisions were add

(pinot) branch dependabot/maven/org.apache.commons-commons-lang3-3.16.0 created (now 5b3b4dd55c)

2024-08-08 Thread github-bot
This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/maven/org.apache.commons-commons-lang3-3.16.0 in repository https://gitbox.apache.org/repos/asf/pinot.git at 5b3b4dd55c Bump org.apache.commons:commons-lang3 from 3.15.0 to

[PR] Bump org.apache.commons:commons-lang3 from 3.15.0 to 3.16.0 [pinot]

2024-08-08 Thread via GitHub
dependabot[bot] opened a new pull request, #13778: URL: https://github.com/apache/pinot/pull/13778 Bumps org.apache.commons:commons-lang3 from 3.15.0 to 3.16.0. [![Dependabot compatibility score](https://dependabot-badges.githubapp.com/badges/compatibility_score?dependency-name=or

[PR] Bump io.grpc:grpc-bom from 1.65.1 to 1.66.0 [pinot]

2024-08-08 Thread via GitHub
dependabot[bot] opened a new pull request, #13777: URL: https://github.com/apache/pinot/pull/13777 Bumps [io.grpc:grpc-bom](https://github.com/grpc/grpc-java) from 1.65.1 to 1.66.0. Commits https://github.com/grpc/grpc-java/commit/cf784069508fc5767a85c915e43bb43ccfc84c76";>cf78

Re: [PR] Optimize NullableSingleInputAggregationFunction when entire block is null [pinot]

2024-08-08 Thread via GitHub
yashmayya commented on PR #13758: URL: https://github.com/apache/pinot/pull/13758#issuecomment-2275218314 @gortiz I used a modified version of the mode aggregation benchmark (with some changes to add a case where all values in the block are `null` and deterministic null handling enabled / d

Re: [PR] add routing policy in query errmsg upon unavailable segments for a bit more context [pinot]

2024-08-08 Thread via GitHub
gortiz commented on code in PR #13706: URL: https://github.com/apache/pinot/pull/13706#discussion_r1708886566 ## pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/BaseSingleStageBrokerRequestHandler.java: ## @@ -836,6 +840,31 @@ protected BrokerResponse handleReq