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 <[email protected]> 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()));
