You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ca...@apache.org on 2023/05/16 07:55:30 UTC
[iotdb] 01/02: comment SetThreadName impl
This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a commit to branch beyyes/optimize_tsbs
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 14b75d77db2217505a5aae4d96e1a6b499563307
Author: Beyyes <cg...@foxmail.com>
AuthorDate: Tue May 16 14:08:38 2023 +0800
comment SetThreadName impl
---
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../db/mpp/plan/scheduler/SimpleQueryTerminator.java | 4 ++++
.../org/apache/iotdb/db/utils/SetThreadName.java | 20 +++++++++-----------
3 files changed, 14 insertions(+), 12 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
index becba4918e..5bd109c6d4 100644
--- a/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
+++ b/server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
@@ -825,7 +825,7 @@ public class IoTDBConfig {
private int frequencyIntervalInMinute = 1;
/** time cost(ms) threshold for slow query. Unit: millisecond */
- private long slowQueryThreshold = 5000;
+ private long slowQueryThreshold = 5000000;
private int patternMatchingThreshold = 1000000;
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleQueryTerminator.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleQueryTerminator.java
index be1712c6c6..6aee653bc0 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleQueryTerminator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/SimpleQueryTerminator.java
@@ -116,6 +116,8 @@ public class SimpleQueryTerminator implements IQueryTerminator {
return true;
}
+ logger.error("!!!!!!!!unexpected!!!!!!!!!");
+
try (SyncDataNodeInternalServiceClient client =
internalServiceClientManager.borrowClient(endPoint)) {
client.cancelQuery(new TCancelQueryReq(queryId.getId(), unfinishedFIs, false));
@@ -153,6 +155,8 @@ public class SimpleQueryTerminator implements IQueryTerminator {
return true;
}
+ logger.error("!!!!!!!!unexpected!!!!!!!!!");
+
try (SyncDataNodeInternalServiceClient client =
internalServiceClientManager.borrowClient(endPoint)) {
client.cancelQuery(new TCancelQueryReq(queryId.getId(), unfinishedFIs, true));
diff --git a/server/src/main/java/org/apache/iotdb/db/utils/SetThreadName.java b/server/src/main/java/org/apache/iotdb/db/utils/SetThreadName.java
index 43adca20b2..e6126b6908 100644
--- a/server/src/main/java/org/apache/iotdb/db/utils/SetThreadName.java
+++ b/server/src/main/java/org/apache/iotdb/db/utils/SetThreadName.java
@@ -20,20 +20,18 @@ package org.apache.iotdb.db.utils;
import java.io.Closeable;
-import static java.util.Objects.requireNonNull;
-
public class SetThreadName implements Closeable {
- private final String originalThreadName;
+ private final String originalThreadName = "";
public SetThreadName(String suffix) {
- requireNonNull(suffix, "suffix is null");
- originalThreadName = Thread.currentThread().getName();
- int index = originalThreadName.indexOf("$");
- if (index < 0) {
- Thread.currentThread().setName(originalThreadName + '$' + suffix);
- } else {
- Thread.currentThread().setName(originalThreadName.substring(0, index) + '$' + suffix);
- }
+ // requireNonNull(suffix, "suffix is null");
+ // originalThreadName = Thread.currentThread().getName();
+ // int index = originalThreadName.indexOf("$");
+ // if (index < 0) {
+ // Thread.currentThread().setName(originalThreadName + '$' + suffix);
+ // } else {
+ // Thread.currentThread().setName(originalThreadName.substring(0, index) + '$' + suffix);
+ // }
}
@Override