Skip to content

Commit 5fd2b81

Browse files
authored
Pipe: Switched some unnecessary log to debug level
1 parent 054fcc7 commit 5fd2b81

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/PipePushMetaRPCHandler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ public void onComplete(TPushPipeMetaResp response) {
5050
responseMap.put(requestId, response);
5151

5252
if (response.getStatus().getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
53-
LOGGER.info("Successfully {} on DataNode: {}", requestType, formattedTargetLocation);
53+
LOGGER.debug("Successfully {} on DataNode: {}", requestType, formattedTargetLocation);
5454
} else {
5555
LOGGER.error(
5656
"Failed to {} on DataNode: {}, response: {}",

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/coordinator/runtime/heartbeat/PipeHeartbeatParser.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -185,7 +185,7 @@ private void parseHeartbeatAndSaveMetaChangeLocally(
185185
final PipeTaskMeta runtimeMetaFromAgent =
186186
pipeTaskMetaMapFromAgent.get(runtimeMetaFromCoordinator.getKey());
187187
if (runtimeMetaFromAgent == null) {
188-
LOGGER.info(
188+
LOGGER.debug(
189189
"No corresponding Pipe is running in the reported DataRegion. runtimeMetaFromAgent is null, runtimeMetaFromCoordinator: {}",
190190
runtimeMetaFromCoordinator);
191191
continue;

iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/pipe/PipeTaskInfo.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -672,7 +672,7 @@ private TSStatus handleMetaChangesInternal(final PipeHandleMetaChangePlan plan)
672672
.forEach(
673673
pipeMeta -> {
674674
pipeMetaKeeper.addPipeMeta(pipeMeta);
675-
logger.ifPresent(l -> l.info("Recording pipe meta: {}", pipeMeta));
675+
logger.ifPresent(l -> l.debug("Recording pipe meta: {}", pipeMeta));
676676
});
677677

678678
return new TSStatus(TSStatusCode.SUCCESS_STATUS.getStatusCode());

0 commit comments

Comments
 (0)