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 2022/08/30 06:20:43 UTC
[iotdb] branch xingtanzjr/change_log_level updated: change log level from info to debug for some logs in MPP
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a commit to branch xingtanzjr/change_log_level
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/xingtanzjr/change_log_level by this push:
new 27a50543a9 change log level from info to debug for some logs in MPP
27a50543a9 is described below
commit 27a50543a97efa0bcb5abbb47173ebca97fec85c
Author: Jinrui.Zhang <xi...@gmail.com>
AuthorDate: Tue Aug 30 14:20:27 2022 +0800
change log level from info to debug for some logs in MPP
---
.../db/mpp/execution/exchange/LocalSinkHandle.java | 16 ++++++++--------
.../db/mpp/execution/exchange/LocalSourceHandle.java | 10 +++++-----
.../execution/exchange/MPPDataExchangeManager.java | 16 ++++++++--------
.../mpp/execution/exchange/SharedTsBlockQueue.java | 2 +-
.../iotdb/db/mpp/execution/exchange/SinkHandle.java | 20 ++++++++++----------
.../db/mpp/execution/exchange/SourceHandle.java | 14 +++++++-------
.../fragment/FragmentInstanceStateMachine.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 8 ++++----
.../iotdb/db/mpp/plan/execution/QueryExecution.java | 12 ++++++------
.../distribution/SimpleFragmentParallelPlanner.java | 2 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 2 +-
.../plan/scheduler/FixedRateFragInsStateTracker.java | 2 +-
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 6 +++---
13 files changed, 56 insertions(+), 56 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandle.java
index aaba4b8d0b..653f61d740 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSinkHandle.java
@@ -113,7 +113,7 @@ public class LocalSinkHandle implements ISinkHandle {
if (queue.hasNoMoreTsBlocks()) {
return;
}
- logger.info("send TsBlocks");
+ logger.debug("send TsBlocks");
synchronized (this) {
blocked = queue.add(tsBlock);
}
@@ -129,9 +129,9 @@ public class LocalSinkHandle implements ISinkHandle {
public void setNoMoreTsBlocks() {
synchronized (queue) {
synchronized (this) {
- logger.info("set noMoreTsBlocks.");
+ logger.debug("set noMoreTsBlocks.");
if (aborted || closed) {
- logger.info("SinkHandle has been aborted={} or closed={}.", aborted, closed);
+ logger.debug("SinkHandle has been aborted={} or closed={}.", aborted, closed);
return;
}
queue.setNoMoreTsBlocks(true);
@@ -139,12 +139,12 @@ public class LocalSinkHandle implements ISinkHandle {
}
}
checkAndInvokeOnFinished();
- logger.info("noMoreTsBlocks has been set.");
+ logger.debug("noMoreTsBlocks has been set.");
}
@Override
public void abort() {
- logger.info("Sink handle is being aborted.");
+ logger.debug("Sink handle is being aborted.");
synchronized (queue) {
synchronized (this) {
if (aborted || closed) {
@@ -155,12 +155,12 @@ public class LocalSinkHandle implements ISinkHandle {
sinkHandleListener.onAborted(this);
}
}
- logger.info("Sink handle is aborted");
+ logger.debug("Sink handle is aborted");
}
@Override
public void close() {
- logger.info("Sink handle is being closed.");
+ logger.debug("Sink handle is being closed.");
synchronized (queue) {
synchronized (this) {
if (aborted || closed) {
@@ -171,7 +171,7 @@ public class LocalSinkHandle implements ISinkHandle {
sinkHandleListener.onFinish(this);
}
}
- logger.info("Sink handle is closed");
+ logger.debug("Sink handle is closed");
}
public TFragmentInstanceId getRemoteFragmentInstanceId() {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandle.java
index 35c7cda823..a6e6b4bf6d 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/LocalSourceHandle.java
@@ -94,7 +94,7 @@ public class LocalSourceHandle implements ISourceHandle {
}
if (tsBlock != null) {
currSequenceId++;
- logger.info(
+ logger.debug(
"Receive {} TsdBlock, size is {}", currSequenceId, tsBlock.getRetainedSizeInBytes());
}
checkAndInvokeOnFinished();
@@ -139,7 +139,7 @@ public class LocalSourceHandle implements ISourceHandle {
return;
}
try (SetThreadName sourceHandleName = new SetThreadName(threadName)) {
- logger.info("Source handle is being aborted.");
+ logger.debug("Source handle is being aborted.");
synchronized (queue) {
synchronized (this) {
if (aborted || closed) {
@@ -150,7 +150,7 @@ public class LocalSourceHandle implements ISourceHandle {
sourceHandleListener.onAborted(this);
}
}
- logger.info("Source handle is aborted");
+ logger.debug("Source handle is aborted");
}
}
@@ -160,7 +160,7 @@ public class LocalSourceHandle implements ISourceHandle {
return;
}
try (SetThreadName sourceHandleName = new SetThreadName(threadName)) {
- logger.info("Source handle is being closed.");
+ logger.debug("Source handle is being closed.");
synchronized (queue) {
synchronized (this) {
if (aborted || closed) {
@@ -171,7 +171,7 @@ public class LocalSourceHandle implements ISourceHandle {
sourceHandleListener.onFinished(this);
}
}
- logger.info("Source handle is closed");
+ logger.debug("Source handle is closed");
}
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
index b2b32222d9..ad3bb7c078 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/MPPDataExchangeManager.java
@@ -215,12 +215,12 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
@Override
public void onFinished(ISourceHandle sourceHandle) {
- logger.info("finished and release resources");
+ logger.debug("finished and release resources");
if (!sourceHandles.containsKey(sourceHandle.getLocalFragmentInstanceId())
|| !sourceHandles
.get(sourceHandle.getLocalFragmentInstanceId())
.containsKey(sourceHandle.getLocalPlanNodeId())) {
- logger.info("resources has already been released");
+ logger.debug("resources has already been released");
} else {
sourceHandles
.get(sourceHandle.getLocalFragmentInstanceId())
@@ -234,7 +234,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
@Override
public void onAborted(ISourceHandle sourceHandle) {
- logger.info("onAborted is invoked");
+ logger.debug("onAborted is invoked");
onFinished(sourceHandle);
}
@@ -273,14 +273,14 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
@Override
public void onAborted(ISinkHandle sinkHandle) {
- logger.info("onAborted is invoked");
+ logger.debug("onAborted is invoked");
removeFromMPPDataExchangeManager(sinkHandle);
}
private void removeFromMPPDataExchangeManager(ISinkHandle sinkHandle) {
- logger.info("release resources of finished sink handle");
+ logger.debug("release resources of finished sink handle");
if (!sinkHandles.containsKey(sinkHandle.getLocalFragmentInstanceId())) {
- logger.info("resources already been released");
+ logger.debug("resources already been released");
}
sinkHandles.remove(sinkHandle.getLocalFragmentInstanceId());
}
@@ -492,7 +492,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
* <p>This method should be called when a fragment instance finished in an abnormal state.
*/
public void forceDeregisterFragmentInstance(TFragmentInstanceId fragmentInstanceId) {
- logger.info("Force deregister fragment instance");
+ logger.debug("Force deregister fragment instance");
if (sinkHandles.containsKey(fragmentInstanceId)) {
ISinkHandle sinkHandle = sinkHandles.get(fragmentInstanceId);
sinkHandle.abort();
@@ -501,7 +501,7 @@ public class MPPDataExchangeManager implements IMPPDataExchangeManager {
if (sourceHandles.containsKey(fragmentInstanceId)) {
Map<String, ISourceHandle> planNodeIdToSourceHandle = sourceHandles.get(fragmentInstanceId);
for (Entry<String, ISourceHandle> entry : planNodeIdToSourceHandle.entrySet()) {
- logger.info("Close source handle {}", sourceHandles);
+ logger.debug("Close source handle {}", sourceHandles);
entry.getValue().abort();
}
sourceHandles.remove(fragmentInstanceId);
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
index 1222ee5ef0..74c579904b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SharedTsBlockQueue.java
@@ -96,7 +96,7 @@ public class SharedTsBlockQueue {
/** Notify no more tsblocks will be added to the queue. */
public void setNoMoreTsBlocks(boolean noMoreTsBlocks) {
- logger.info("SharedTsBlockQueue receive no more TsBlocks signal.");
+ logger.debug("SharedTsBlockQueue receive no more TsBlocks signal.");
if (closed) {
logger.warn("queue has been destroyed");
return;
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandle.java
index 4cc0539a01..f93493aafa 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SinkHandle.java
@@ -167,7 +167,7 @@ public class SinkHandle implements ISinkHandle {
}
private void sendEndOfDataBlockEvent() throws Exception {
- logger.info("send end of data block event");
+ logger.debug("send end of data block event");
int attempt = 0;
TEndOfDataBlockEvent endOfDataBlockEvent =
new TEndOfDataBlockEvent(
@@ -193,7 +193,7 @@ public class SinkHandle implements ISinkHandle {
@Override
public synchronized void setNoMoreTsBlocks() {
- logger.info("start to set no-more-tsblocks");
+ logger.debug("start to set no-more-tsblocks");
if (aborted || closed) {
return;
}
@@ -202,20 +202,20 @@ public class SinkHandle implements ISinkHandle {
} catch (Exception e) {
throw new RuntimeException("Send EndOfDataBlockEvent failed", e);
}
- logger.info("set noMoreTsBlocks to true");
+ logger.debug("set noMoreTsBlocks to true");
noMoreTsBlocks = true;
if (isFinished()) {
- logger.info("revoke onFinish() of sinkHandleListener");
+ logger.debug("revoke onFinish() of sinkHandleListener");
sinkHandleListener.onFinish(this);
}
- logger.info("revoke onEndOfBlocks() of sinkHandleListener");
+ logger.debug("revoke onEndOfBlocks() of sinkHandleListener");
sinkHandleListener.onEndOfBlocks(this);
}
@Override
public synchronized void abort() {
- logger.info("SinkHandle is being aborted.");
+ logger.debug("SinkHandle is being aborted.");
sequenceIdToTsBlock.clear();
aborted = true;
bufferRetainedSizeInBytes -= localMemoryManager.getQueryPool().tryCancel(blocked);
@@ -226,12 +226,12 @@ public class SinkHandle implements ISinkHandle {
bufferRetainedSizeInBytes = 0;
}
sinkHandleListener.onAborted(this);
- logger.info("SinkHandle is aborted");
+ logger.debug("SinkHandle is aborted");
}
@Override
public synchronized void close() {
- logger.info("SinkHandle is being closed.");
+ logger.debug("SinkHandle is being closed.");
sequenceIdToTsBlock.clear();
closed = true;
bufferRetainedSizeInBytes -= localMemoryManager.getQueryPool().tryComplete(blocked);
@@ -242,7 +242,7 @@ public class SinkHandle implements ISinkHandle {
bufferRetainedSizeInBytes = 0;
}
sinkHandleListener.onFinish(this);
- logger.info("SinkHandle is closed");
+ logger.debug("SinkHandle is closed");
}
@Override
@@ -375,7 +375,7 @@ public class SinkHandle implements ISinkHandle {
@Override
public void run() {
try (SetThreadName sinkHandleName = new SetThreadName(threadName)) {
- logger.info(
+ logger.debug(
"Send new data block event [{}, {})",
startSequenceId,
startSequenceId + blockSizes.size());
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandle.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandle.java
index c0a353f8b9..6fccaf8511 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandle.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/exchange/SourceHandle.java
@@ -130,13 +130,13 @@ public class SourceHandle implements ISourceHandle {
return null;
}
long retainedSize = sequenceIdToDataBlockSize.remove(currSequenceId);
- logger.info("Receive {} TsBlock, size is {}", currSequenceId, retainedSize);
+ logger.debug("Receive {} TsBlock, size is {}", currSequenceId, retainedSize);
currSequenceId += 1;
bufferRetainedSizeInBytes -= retainedSize;
localMemoryManager.getQueryPool().free(localFragmentInstanceId.getQueryId(), retainedSize);
if (sequenceIdToTsBlock.isEmpty() && !isFinished()) {
- logger.info("no buffered TsBlock, blocked");
+ logger.debug("no buffered TsBlock, blocked");
blocked = SettableFuture.create();
}
if (isFinished()) {
@@ -222,7 +222,7 @@ public class SourceHandle implements ISourceHandle {
}
synchronized void setNoMoreTsBlocks(int lastSequenceId) {
- logger.info("receive NoMoreTsBlock event. ");
+ logger.debug("receive NoMoreTsBlock event. ");
this.lastSequenceId = lastSequenceId;
if (!blocked.isDone() && remoteTsBlockedConsumedUp()) {
blocked.set(null);
@@ -233,7 +233,7 @@ public class SourceHandle implements ISourceHandle {
}
synchronized void updatePendingDataBlockInfo(int startSequenceId, List<Long> dataBlockSizes) {
- logger.info(
+ logger.debug(
"receive newDataBlockEvent. [{}, {}), each size is: {}",
startSequenceId,
startSequenceId + dataBlockSizes.size(),
@@ -380,7 +380,7 @@ public class SourceHandle implements ISourceHandle {
@Override
public void run() {
try (SetThreadName sourceHandleName = new SetThreadName(threadName)) {
- logger.info("try to get data blocks [{}, {}) ", startSequenceId, endSequenceId);
+ logger.debug("try to get data blocks [{}, {}) ", startSequenceId, endSequenceId);
TGetDataBlockRequest req =
new TGetDataBlockRequest(remoteFragmentInstanceId, startSequenceId, endSequenceId);
int attempt = 0;
@@ -394,7 +394,7 @@ public class SourceHandle implements ISourceHandle {
TsBlock tsBlock = serde.deserialize(byteBuffer);
tsBlocks.add(tsBlock);
}
- logger.info("got data blocks. count: {}", tsBlocks.size());
+ logger.debug("got data blocks. count: {}", tsBlocks.size());
executorService.submit(
new SendAcknowledgeDataBlockEventTask(startSequenceId, endSequenceId));
synchronized (SourceHandle.this) {
@@ -447,7 +447,7 @@ public class SourceHandle implements ISourceHandle {
@Override
public void run() {
try (SetThreadName sourceHandleName = new SetThreadName(threadName)) {
- logger.info("send ack data block event [{}, {}).", startSequenceId, endSequenceId);
+ logger.debug("send ack data block event [{}, {}).", startSequenceId, endSequenceId);
int attempt = 0;
TAcknowledgeDataBlockEvent acknowledgeDataBlockEvent =
new TAcknowledgeDataBlockEvent(
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
index 699777d8f0..d903f6eb13 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceStateMachine.java
@@ -78,7 +78,7 @@ public class FragmentInstanceStateMachine {
instanceState.addStateChangeListener(
newState -> {
try (SetThreadName threadName = new SetThreadName(fragmentInstanceId.getFullId())) {
- LOGGER.info("State transfer to {}", newState);
+ LOGGER.debug("State transfer to {}", newState);
}
});
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
index 8d271db790..cf82f6e63b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java
@@ -174,9 +174,9 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext>
analysis.setStatement(queryStatement);
// request schema fetch API
- logger.info("{} fetch query schema...", getLogHeader());
+ logger.debug("{} fetch query schema...", getLogHeader());
ISchemaTree schemaTree = schemaFetcher.fetchSchema(patternTree);
- logger.info("{} fetch schema done", getLogHeader());
+ logger.debug("{} fetch schema done", getLogHeader());
// If there is no leaf node in the schema tree, the query should be completed immediately
if (schemaTree.isEmpty()) {
if (queryStatement.isLastQuery()) {
@@ -1386,9 +1386,9 @@ public class AnalyzeVisitor extends StatementVisitor<Analysis, MPPQueryContext>
if (showTimeSeriesStatement.isOrderByHeat()) {
patternTree.constructTree();
// request schema fetch API
- logger.info("{} fetch query schema...", getLogHeader());
+ logger.debug("{} fetch query schema...", getLogHeader());
ISchemaTree schemaTree = schemaFetcher.fetchSchema(patternTree);
- logger.info("{} fetch schema done", getLogHeader());
+ logger.debug("{} fetch schema done", getLogHeader());
List<MeasurementPath> allSelectedPath = schemaTree.getAllMeasurement();
Set<Expression> sourceExpressions =
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
index e9d6857ae1..4522caea0b 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/QueryExecution.java
@@ -153,7 +153,7 @@ public class QueryExecution implements IQueryExecution {
if (state == QueryState.FAILED
|| state == QueryState.ABORTED
|| state == QueryState.CANCELED) {
- logger.info("release resource because Query State is: {}", state);
+ logger.debug("release resource because Query State is: {}", state);
releaseResource();
}
}
@@ -162,7 +162,7 @@ public class QueryExecution implements IQueryExecution {
public void start() {
if (skipExecute()) {
- logger.info("execution of query will be skipped. Transit to RUNNING immediately.");
+ logger.debug("execution of query will be skipped. Transit to RUNNING immediately.");
constructResultForMemorySource();
stateMachine.transitionToRunning();
return;
@@ -260,7 +260,7 @@ public class QueryExecution implements IQueryExecution {
LogicalPlanner planner = new LogicalPlanner(this.context, this.planOptimizers);
this.logicalPlan = planner.plan(this.analysis);
if (isQuery()) {
- logger.info(
+ logger.debug(
"logical plan is: \n {}", PlanNodeUtil.nodeToString(this.logicalPlan.getRootNode()));
}
}
@@ -270,7 +270,7 @@ public class QueryExecution implements IQueryExecution {
DistributionPlanner planner = new DistributionPlanner(this.analysis, this.logicalPlan);
this.distributedPlan = planner.planFragments();
if (isQuery()) {
- logger.info(
+ logger.debug(
"distribution plan done. Fragment instance count is {}, details is: \n {}",
distributedPlan.getInstances().size(),
printFragmentInstances(distributedPlan.getInstances()));
@@ -326,7 +326,7 @@ public class QueryExecution implements IQueryExecution {
while (true) {
try {
if (resultHandle.isAborted()) {
- logger.info("resultHandle for client is aborted");
+ logger.debug("resultHandle for client is aborted");
stateMachine.transitionToAborted();
if (stateMachine.getFailureStatus() != null) {
throw new IoTDBException(
@@ -339,7 +339,7 @@ public class QueryExecution implements IQueryExecution {
// Once the resultHandle is finished, we should transit the state of this query to
// FINISHED.
// So that the corresponding cleanup work could be triggered.
- logger.info("resultHandle for client is finished");
+ logger.debug("resultHandle for client is finished");
stateMachine.transitionToFinished();
return Optional.empty();
}
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SimpleFragmentParallelPlanner.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SimpleFragmentParallelPlanner.java
index d5c73f6822..e4ba381316 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SimpleFragmentParallelPlanner.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SimpleFragmentParallelPlanner.java
@@ -142,7 +142,7 @@ public class SimpleFragmentParallelPlanner implements IFragmentParallelPlaner {
throw new IllegalArgumentException(errorMsg);
}
if (regionReplicaSet.getDataNodeLocationsSize() != availableDataNodes.size()) {
- logger.info("available replicas: " + availableDataNodes);
+ logger.debug("available replicas: " + availableDataNodes);
}
int targetIndex;
if (!selectRandomDataNode || queryContext.getSession() == null) {
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java
index 115774169d..09855df753 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/ClusterScheduler.java
@@ -133,7 +133,7 @@ public class ClusterScheduler implements IScheduler {
// TODO: (xingtanzjr) start the stateFetcher/heartbeat for each fragment instance
this.stateTracker.start();
- logger.info("state tracker starts");
+ logger.debug("state tracker starts");
}
@Override
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FixedRateFragInsStateTracker.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FixedRateFragInsStateTracker.java
index 08563d9361..3081d2c69f 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FixedRateFragInsStateTracker.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/FixedRateFragInsStateTracker.java
@@ -100,7 +100,7 @@ public class FixedRateFragInsStateTracker extends AbstractFragInsStateTracker {
instanceStateMap.computeIfAbsent(
instance.getId(), k -> new InstanceStateMetrics(instance.isRoot()));
if (needPrintState(metrics.lastState, state, metrics.durationToLastPrintInMS)) {
- logger.info("State is {}", state);
+ logger.debug("State is {}", state);
metrics.reset(state);
} else {
metrics.addDuration(STATE_FETCH_INTERVAL_IN_MS);
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
index fb48c43e04..424b62cd01 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/plan/scheduler/StandaloneScheduler.java
@@ -120,14 +120,14 @@ public class StandaloneScheduler implements IScheduler {
}
} catch (Exception e) {
stateMachine.transitionToFailed(e);
- LOGGER.info("transit to FAILED");
+ LOGGER.debug("transit to FAILED");
return;
}
// The FragmentInstances has been dispatched successfully to corresponding host, we mark the
stateMachine.transitionToRunning();
- LOGGER.info("transit to RUNNING");
+ LOGGER.debug("transit to RUNNING");
this.stateTracker.start();
- LOGGER.info("state tracker starts");
+ LOGGER.debug("state tracker starts");
break;
case WRITE:
// reject non-query operations when system is read-only