This is an automated email from the ASF dual-hosted git repository.
xiangfu 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 43f92c4f043 Add error message for leaf stage errors (#17207)
43f92c4f043 is described below
commit 43f92c4f04320ca1f590233c4395e2adc7be7299
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Thu Nov 13 17:55:50 2025 -0800
Add error message for leaf stage errors (#17207)
---
.../java/org/apache/pinot/query/runtime/operator/LeafOperator.java | 4 ++++
1 file changed, 4 insertions(+)
diff --git
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/LeafOperator.java
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/LeafOperator.java
index 6dbe9e6bb0b..4fd8fb8dc50 100644
---
a/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/LeafOperator.java
+++
b/pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/LeafOperator.java
@@ -426,6 +426,7 @@ public class LeafOperator extends MultiStageOperator {
try {
execute();
} catch (Exception e) {
+ LOGGER.error("Caught exception while executing leaf stage", e);
setErrorBlock(
ErrorMseBlock.fromError(QueryErrorCode.INTERNAL, "Caught exception
while executing leaf stage: " + e));
} finally {
@@ -460,6 +461,9 @@ public class LeafOperator extends MultiStageOperator {
try {
// Drain the latch when receiving exception block and not wait for
the other thread to finish
executeOneRequest(request, latch::countDown);
+ } catch (Throwable t) {
+ // TODO: We need to propagate this error back
+ LOGGER.error("Caught exception while executing leaf stage on
hybrid table", t);
} finally {
latch.countDown();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
