This is an automated email from the ASF dual-hosted git repository.
jiaguo 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 3d07b90bd7 Fix Logging Location for CPU-Based Query Killing (#13318)
3d07b90bd7 is described below
commit 3d07b90bd7568292295149fb7fe965f3b2605d78
Author: PraveenVora <[email protected]>
AuthorDate: Thu Jun 6 01:59:02 2024 +0530
Fix Logging Location for CPU-Based Query Killing (#13318)
* fix logging
* fix logging
---------
Co-authored-by: pchaganl <[email protected]>
---
.../pinot/core/accounting/PerQueryCPUMemAccountantFactory.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/pinot-core/src/main/java/org/apache/pinot/core/accounting/PerQueryCPUMemAccountantFactory.java
b/pinot-core/src/main/java/org/apache/pinot/core/accounting/PerQueryCPUMemAccountantFactory.java
index 5b724f4a0f..598b68b344 100644
---
a/pinot-core/src/main/java/org/apache/pinot/core/accounting/PerQueryCPUMemAccountantFactory.java
+++
b/pinot-core/src/main/java/org/apache/pinot/core/accounting/PerQueryCPUMemAccountantFactory.java
@@ -827,8 +827,9 @@ public class PerQueryCPUMemAccountantFactory implements
ThreadAccountantFactory
for (Map.Entry<String, AggregatedStats> entry :
_aggregatedUsagePerActiveQuery.entrySet()) {
AggregatedStats value = entry.getValue();
if (value._cpuNS > _cpuTimeBasedKillingThresholdNS) {
- LOGGER.error("Query {} got picked because using {} ns of cpu time,
greater than threshold {}",
- value._queryId, value.getCpuNS(),
_cpuTimeBasedKillingThresholdNS);
+ LOGGER.error("Current task status recorded is {}. Query {} got
picked because using {} ns of cpu time,"
+ + " greater than threshold {}", _threadEntriesMap,
value._queryId, value.getCpuNS(),
+ _cpuTimeBasedKillingThresholdNS);
value._exceptionAtomicReference.set(new RuntimeException(
String.format("Query %s got killed on %s: %s because using %d "
+ "CPU time exceeding limit of %d ns CPU time",
@@ -836,7 +837,6 @@ public class PerQueryCPUMemAccountantFactory implements
ThreadAccountantFactory
interruptRunnerThread(value.getAnchorThread());
}
}
- LOGGER.error("Current task status recorded is {}", _threadEntriesMap);
}
private void interruptRunnerThread(Thread thread) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
