This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch master_performance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master_performance by this
push:
new 1489035 add info logs (#4464)
1489035 is described below
commit 1489035bef6dc52e0743e5b45ac0b8fb59080775
Author: Mrquan <[email protected]>
AuthorDate: Thu Nov 25 17:26:12 2021 +0800
add info logs (#4464)
Co-authored-by: 权思屹 <[email protected]>
---
server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java | 1 +
.../apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java | 3 +++
.../org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java | 3 +++
.../src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java | 1 +
service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java | 6 ++++++
.../src/main/java/org/apache/iotdb/session/SessionConnection.java | 1 +
6 files changed, 15 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
index d3497ee..705df0e 100644
--- a/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
+++ b/server/src/main/java/org/apache/iotdb/db/engine/StorageEngine.java
@@ -624,6 +624,7 @@ public class StorageEngine implements IService {
try {
blockInsertionIfReject(null);
} catch (WriteProcessRejectException e) {
+ logger.info("Insert tablet reject");
TSStatus[] results = new TSStatus[insertTabletPlan.getRowCount()];
Arrays.fill(results,
RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT));
throw new BatchProcessException(results);
diff --git
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
index 43e3154..3e3dce3 100755
---
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
+++
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessor.java
@@ -950,6 +950,7 @@ public class StorageGroupProcessor {
long currTime = insertTabletPlan.getTimes()[loc];
// skip points that do not satisfy TTL
if (!isAlive(currTime)) {
+ logger.info("Insert tablet out of TTL");
results[loc] =
RpcUtils.getStatus(
TSStatusCode.OUT_OF_TTL_ERROR,
@@ -962,6 +963,7 @@ public class StorageGroupProcessor {
}
// loc pointing at first legal position
if (loc == insertTabletPlan.getRowCount()) {
+ logger.info("Insert tablet out of TTL of all points");
throw new BatchProcessException(results);
}
@@ -1080,6 +1082,7 @@ public class StorageGroupProcessor {
TsFileProcessor tsFileProcessor =
getOrCreateTsFileProcessor(timePartitionId, sequence);
if (tsFileProcessor == null) {
for (int i = start; i < end; i++) {
+ logger.info("Insert tablet: internal_server_error");
results[i] =
RpcUtils.getStatus(
TSStatusCode.INTERNAL_SERVER_ERROR,
diff --git
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
index 5908597..09043a0 100644
---
a/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+++
b/server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
@@ -286,6 +286,7 @@ public class TsFileProcessor {
}
} catch (WriteProcessException e) {
for (int i = start; i < end; i++) {
+ logger.info("Insert tablet: write_process_reject");
results[i] = RpcUtils.getStatus(TSStatusCode.WRITE_PROCESS_REJECT,
e.getMessage());
}
throw new WriteProcessException(e);
@@ -299,6 +300,7 @@ public class TsFileProcessor {
}
} catch (Exception e) {
for (int i = start; i < end; i++) {
+ logger.info("Insert tablet: internal_server_error");
results[i] = RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR,
e.getMessage());
}
if (enableMemControl && memIncrements != null) {
@@ -315,6 +317,7 @@ public class TsFileProcessor {
}
} catch (WriteProcessException e) {
for (int i = start; i < end; i++) {
+ logger.info("Insert tablet: internal_server_error");
results[i] = RpcUtils.getStatus(TSStatusCode.INTERNAL_SERVER_ERROR,
e.getMessage());
}
throw new WriteProcessException(e);
diff --git
a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
index a7052fa..5abed89 100644
--- a/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
+++ b/server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
@@ -1530,6 +1530,7 @@ public class PlanExecutor implements IPlanExecutor {
return;
}
try {
+ logger.info("Execute insert tablet {}", insertTabletPlan.getRowCount());
insertTabletPlan.setMeasurementMNodes(
new IMeasurementMNode[insertTabletPlan.getMeasurements().length]);
getSeriesSchemas(insertTabletPlan);
diff --git a/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
b/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
index b4866e3..60edbca 100644
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
@@ -24,6 +24,9 @@ import org.apache.iotdb.service.rpc.thrift.TSFetchResultsResp;
import org.apache.iotdb.service.rpc.thrift.TSIService;
import org.apache.iotdb.service.rpc.thrift.TSStatus;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
import java.lang.reflect.Proxy;
import java.text.SimpleDateFormat;
import java.time.Instant;
@@ -36,6 +39,7 @@ import java.util.Map;
public class RpcUtils {
+ private static final Logger logger = LoggerFactory.getLogger(RpcUtils.class);
/** How big should the default read and write buffers be? Defaults to 1KB */
public static final int THRIFT_DEFAULT_BUF_CAPACITY = 1024;
/**
@@ -112,11 +116,13 @@ public class RpcUtils {
}
public static void verifySuccess(List<TSStatus> statuses) throws
BatchExecutionException {
+ logger.info("Multiple error in executing insert tablet, sub status: {}",
statuses.size());
StringBuilder errMsgs = new StringBuilder();
for (TSStatus status : statuses) {
if (status.getCode() != TSStatusCode.SUCCESS_STATUS.getStatusCode()
&& status.getCode() !=
TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
errMsgs.append(status.getMessage()).append(";");
+ logger.info("error status {} ", status.getCode());
}
}
if (errMsgs.length() > 0) {
diff --git
a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
index de6350e..2a3733e 100644
--- a/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
+++ b/session/src/main/java/org/apache/iotdb/session/SessionConnection.java
@@ -560,6 +560,7 @@ public class SessionConnection {
throws IoTDBConnectionException, StatementExecutionException,
RedirectException {
request.setSessionId(sessionId);
try {
+ logger.info("Execute insert tablet {}", request.getSize());
RpcUtils.verifySuccessWithRedirection(client.insertTablet(request));
} catch (TException e) {
if (reconnect()) {
