You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2023/02/02 17:36:10 UTC
[iotdb] 01/02: tmp save for debug geely
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch geely_car_session_pool
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 79fb9683ed8f9eeca47d024a1336fdf86cbb2849
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Fri Feb 3 01:08:58 2023 +0800
tmp save for debug geely
---
.../db/metadata/cache/DataNodeSchemaCache.java | 1 +
.../metadata/visitor/SchemaExecutionVisitor.java | 2 +-
.../execution/executor/RegionWriteExecutor.java | 20 ++++++++++----------
.../scheduler/FragmentInstanceDispatcherImpl.java | 22 +++++++++++-----------
4 files changed, 23 insertions(+), 22 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java b/server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java
index a3a47d07a8..42f75406f0 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/cache/DataNodeSchemaCache.java
@@ -59,6 +59,7 @@ public class DataNodeSchemaCache {
.weigher(
(PartialPath key, SchemaCacheEntry value) ->
PartialPath.estimateSize(key) + SchemaCacheEntry.estimateSize(value))
+ .recordStats()
.build();
MetricService.getInstance().addMetricSet(new DataNodeSchemaCacheMetrics(this));
}
diff --git a/server/src/main/java/org/apache/iotdb/db/metadata/visitor/SchemaExecutionVisitor.java b/server/src/main/java/org/apache/iotdb/db/metadata/visitor/SchemaExecutionVisitor.java
index d69597fca8..612cc36d14 100644
--- a/server/src/main/java/org/apache/iotdb/db/metadata/visitor/SchemaExecutionVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/metadata/visitor/SchemaExecutionVisitor.java
@@ -213,7 +213,7 @@ public class SchemaExecutionVisitor extends PlanVisitor<TSStatus, ISchemaRegion>
schemaRegion.createTimeseries(
transformToCreateTimeSeriesPlan(devicePath, measurementGroup, i), -1);
} catch (MeasurementAlreadyExistException e) {
- logger.info("There's no need to internal create timeseries. {}", e.getMessage());
+ // logger.info("There's no need to internal create timeseries. {}", e.getMessage());
alreadyExistingTimeseries.add(
RpcUtils.getStatus(
e.getErrorCode(), MeasurementPath.transformDataToString(e.getMeasurementPath())));
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
index b237707483..045936ebf0 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/executor/RegionWriteExecutor.java
@@ -222,7 +222,7 @@ public class RegionWriteExecutor {
String.format(
"Fail to insert measurements %s caused by %s",
insertNode.getFailedMeasurements(), insertNode.getFailedMessages());
- LOGGER.warn(partialInsertMessage);
+ // LOGGER.warn(partialInsertMessage);
}
ConsensusWriteResponse writeResponse =
@@ -246,9 +246,9 @@ public class RegionWriteExecutor {
response.setMessage(writeResponse.getStatus().message);
}
} else {
- LOGGER.warn(
- "Something wrong happened while calling consensus layer's write API.",
- writeResponse.getException());
+ // LOGGER.warn(
+ // "Something wrong happened while calling consensus layer's write API.",
+ // writeResponse.getException());
response.setAccepted(false);
response.setMessage(writeResponse.getException().toString());
response.setStatus(
@@ -432,9 +432,9 @@ public class RegionWriteExecutor {
metadataException = failingMeasurement.getValue();
if (metadataException.getErrorCode()
== TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
- LOGGER.info(
- "There's no need to internal create timeseries. {}",
- failingMeasurement.getValue().getMessage());
+ // LOGGER.info(
+ // "There's no need to internal create timeseries. {}",
+ // failingMeasurement.getValue().getMessage());
alreadyExistingStatus.add(
RpcUtils.getStatus(
metadataException.getErrorCode(),
@@ -532,9 +532,9 @@ public class RegionWriteExecutor {
metadataException = failingMeasurement.getValue();
if (metadataException.getErrorCode()
== TSStatusCode.TIMESERIES_ALREADY_EXIST.getStatusCode()) {
- LOGGER.info(
- "There's no need to internal create timeseries. {}",
- failingMeasurement.getValue().getMessage());
+ // LOGGER.info(
+ // "There's no need to internal create timeseries. {}",
+ // failingMeasurement.getValue().getMessage());
alreadyExistingStatus.add(
RpcUtils.getStatus(
metadataException.getErrorCode(),
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
index cedfdbb684..46bd4bebb7 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FragmentInstanceDispatcherImpl.java
@@ -125,7 +125,7 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
} catch (FragmentInstanceDispatchException e) {
return immediateFuture(new FragInstanceDispatchResult(e.getFailureStatus()));
} catch (Throwable t) {
- logger.warn("[DispatchFailed]", t);
+ // logger.warn("[DispatchFailed]", t);
return immediateFuture(
new FragInstanceDispatchResult(
RpcUtils.getStatus(
@@ -177,12 +177,12 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
instance.getRegionReplicaSet().getRegionId());
TSendPlanNodeResp sendPlanNodeResp = client.sendPlanNode(sendPlanNodeReq);
if (!sendPlanNodeResp.accepted) {
- logger.warn(
- "dispatch write failed. status: {}, code: {}, message: {}, node {}",
- sendPlanNodeResp.status,
- TSStatusCode.representOf(sendPlanNodeResp.status.code),
- sendPlanNodeResp.message,
- endPoint);
+ // logger.warn(
+ // "dispatch write failed. status: {}, code: {}, message: {}, node {}",
+ // sendPlanNodeResp.status,
+ // TSStatusCode.representOf(sendPlanNodeResp.status.code),
+ // sendPlanNodeResp.message,
+ // endPoint);
if (sendPlanNodeResp.getStatus() == null) {
throw new FragmentInstanceDispatchException(
RpcUtils.getStatus(
@@ -245,10 +245,10 @@ public class FragmentInstanceDispatcherImpl implements IFragInstanceDispatcher {
RegionWriteExecutor writeExecutor = new RegionWriteExecutor();
RegionExecutionResult writeResult = writeExecutor.execute(groupId, planNode);
if (!writeResult.isAccepted()) {
- logger.warn(
- "write locally failed. TSStatus: {}, message: {}",
- writeResult.getStatus(),
- writeResult.getMessage());
+ // logger.warn(
+ // "write locally failed. TSStatus: {}, message: {}",
+ // writeResult.getStatus(),
+ // writeResult.getMessage());
if (writeResult.getStatus() == null) {
throw new FragmentInstanceDispatchException(
RpcUtils.getStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR, writeResult.getMessage()));