You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by jl...@apache.org on 2021/12/20 21:51:56 UTC
[pinot] branch add-instance-id-in-response created (now dfaf9e9)
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a change to branch add-instance-id-in-response
in repository https://gitbox.apache.org/repos/asf/pinot.git.
at dfaf9e9 Add instance id in response
This branch includes the following new commits:
new dfaf9e9 Add instance id in response
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[pinot] 01/01: Add instance id in response
Posted by jl...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
jlli pushed a commit to branch add-instance-id-in-response
in repository https://gitbox.apache.org/repos/asf/pinot.git
commit dfaf9e969e27c1b3e45b6f27bbe80110be36f540
Author: Jack Li(Analytics Engineering) <jl...@jlli-mn1.linkedin.biz>
AuthorDate: Mon Dec 20 13:51:06 2021 -0800
Add instance id in response
---
.../pinot/core/query/executor/ServerQueryExecutorV1Impl.java | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/pinot-core/src/main/java/org/apache/pinot/core/query/executor/ServerQueryExecutorV1Impl.java b/pinot-core/src/main/java/org/apache/pinot/core/query/executor/ServerQueryExecutorV1Impl.java
index ca07815..c0a0ab3 100644
--- a/pinot-core/src/main/java/org/apache/pinot/core/query/executor/ServerQueryExecutorV1Impl.java
+++ b/pinot-core/src/main/java/org/apache/pinot/core/query/executor/ServerQueryExecutorV1Impl.java
@@ -145,9 +145,9 @@ public class ServerQueryExecutorV1Impl implements QueryExecutor {
long querySchedulingTimeMs = System.currentTimeMillis() - queryArrivalTimeMs;
if (querySchedulingTimeMs >= queryTimeoutMs) {
_serverMetrics.addMeteredTableValue(tableNameWithType, ServerMeter.SCHEDULING_TIMEOUT_EXCEPTIONS, 1);
- String errorMessage =
- String.format("Query scheduling took %dms (longer than query timeout of %dms)", querySchedulingTimeMs,
- queryTimeoutMs);
+ String errorMessage = String
+ .format("Query scheduling took %dms (longer than query timeout of %dms) on server: %s", querySchedulingTimeMs,
+ queryTimeoutMs, _instanceDataManager.getInstanceId());
DataTable dataTable = DataTableBuilder.getEmptyDataTable();
dataTable.addException(QueryException.getException(QueryException.QUERY_SCHEDULING_TIMEOUT_ERROR, errorMessage));
LOGGER.error("{} while processing requestId: {}", errorMessage, requestId);
@@ -156,7 +156,8 @@ public class ServerQueryExecutorV1Impl implements QueryExecutor {
TableDataManager tableDataManager = _instanceDataManager.getTableDataManager(tableNameWithType);
if (tableDataManager == null) {
- String errorMessage = "Failed to find table: " + tableNameWithType;
+ String errorMessage = String
+ .format("Failed to find table: %s on server: %s", tableNameWithType, _instanceDataManager.getInstanceId());
DataTable dataTable = DataTableBuilder.getEmptyDataTable();
dataTable.addException(QueryException.getException(QueryException.SERVER_TABLE_MISSING_ERROR, errorMessage));
LOGGER.error("{} while processing requestId: {}", errorMessage, requestId);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org