This is an automated email from the ASF dual-hosted git repository.
jt2594838 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new ec81de1f9f2 Reduce pipe load success log noise (#18106)
ec81de1f9f2 is described below
commit ec81de1f9f264b30e4bbf0a738b82d82069eae36
Author: Caideyipi <[email protected]>
AuthorDate: Fri Jul 10 10:18:43 2026 +0800
Reduce pipe load success log noise (#18106)
* Reduce pipe load success log noise
* Fix table cluster IT failures
---
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../iotdb/db/i18n/DataNodeQueryMessages.java | 2 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 65 +++++++++++++------
.../metadata/fetcher/SchemaPredicateUtil.java | 3 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 75 ++++++++++++++--------
.../plan/scheduler/load/LoadTsFileScheduler.java | 27 ++++++--
.../db/storageengine/dataregion/DataRegion.java | 41 +++++++++---
.../commons/pipe/receiver/IoTDBFileReceiver.java | 10 +--
.../commons/pipe/receiver/IoTDBReceiverAgent.java | 4 +-
9 files changed, 158 insertions(+), 71 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
index f32079208fd..b540ebb2540 100644
---
a/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
+++
b/iotdb-core/datanode/src/main/i18n/en/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
@@ -1114,6 +1114,8 @@ public final class DataNodeQueryMessages {
"cancel query {} on node {} failed.";
public static final String CANNOT_DISPATCH_FI_FOR_LOAD_OPERATION =
"cannot dispatch FI for load operation";
+ public static final String MESSAGE_UNEXPECTED_ERRORS_ARG_78EE0800 =
+ "Unexpected errors: %s";
public static final String RECEIVE_LOAD_NODE_FROM_UUID =
"Receive load node from uuid {}.";
public static final String LOAD_TSFILE_NODE_ERROR =
diff --git
a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
index 9e4a0188a11..0e73bd1dd96 100644
---
a/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
+++
b/iotdb-core/datanode/src/main/i18n/zh/org/apache/iotdb/db/i18n/DataNodeQueryMessages.java
@@ -1098,6 +1098,8 @@ public final class DataNodeQueryMessages {
"在节点 {} 上取消查询 {} 失败。";
public static final String CANNOT_DISPATCH_FI_FOR_LOAD_OPERATION =
"无法为加载操作分发 FI";
+ public static final String MESSAGE_UNEXPECTED_ERRORS_ARG_78EE0800 =
+ "意外错误：%s";
public static final String RECEIVE_LOAD_NODE_FROM_UUID =
"接收来自 uuid {} 的加载节点。";
public static final String LOAD_TSFILE_NODE_ERROR =
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
index 89b2f8f2c52..158f38875e1 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileAnalyzer.java
@@ -237,7 +237,11 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
return analysis;
}
-
LOGGER.info(DataNodeQueryMessages.LOAD_ANALYSIS_STAGE_ALL_TSFILES_HAVE_BEEN_ANALYZED);
+ if (isGeneratedByPipe) {
+
LOGGER.debug(DataNodeQueryMessages.LOAD_ANALYSIS_STAGE_ALL_TSFILES_HAVE_BEEN_ANALYZED);
+ } else {
+
LOGGER.info(DataNodeQueryMessages.LOAD_ANALYSIS_STAGE_ALL_TSFILES_HAVE_BEEN_ANALYZED);
+ }
setTsFileModelInfoToStatement();
if (reconstructStatementIfMiniFileConverted()) {
@@ -319,28 +323,14 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
if (LOGGER.isWarnEnabled()) {
LOGGER.warn(DataNodeQueryMessages.TSFILE_IS_EMPTY, tsFile.getPath());
}
- if (LOGGER.isInfoEnabled()) {
- LOGGER.info(
- DataNodeQueryMessages
-
.LOAD_ANALYSIS_STAGE_ARG_ARG_TSFILES_HAVE_BEEN_ANALYZED_PROGRESS_ARG_PERCENT,
- i + 1,
- tsfileNum,
- String.format("%.3f", (i + 1) * 100.00 / tsfileNum));
- }
+ logAnalyzeProgress(i + 1, tsfileNum);
continue;
}
final long startTime = System.nanoTime();
try {
analyzeSingleTsFile(tsFile, i);
- if (LOGGER.isInfoEnabled()) {
- LOGGER.info(
- DataNodeQueryMessages
-
.LOAD_ANALYSIS_STAGE_ARG_ARG_TSFILES_HAVE_BEEN_ANALYZED_PROGRESS_ARG_PERCENT,
- i + 1,
- tsfileNum,
- String.format("%.3f", (i + 1) * 100.00 / tsfileNum));
- }
+ logAnalyzeProgress(i + 1, tsfileNum);
} catch (AuthException e) {
setFailAnalysisForAuthException(analysis, e);
return false;
@@ -379,16 +369,49 @@ public class LoadTsFileAnalyzer implements AutoCloseable {
return true;
}
+ private void logAnalyzeProgress(final int analyzedTsFileNum, final int
totalTsFileNum) {
+ if (isGeneratedByPipe && !LOGGER.isDebugEnabled()) {
+ return;
+ }
+ if (!isGeneratedByPipe && !LOGGER.isInfoEnabled()) {
+ return;
+ }
+
+ final String progress = String.format("%.3f", analyzedTsFileNum * 100.00 /
totalTsFileNum);
+ if (isGeneratedByPipe) {
+ LOGGER.debug(
+ DataNodeQueryMessages
+
.LOAD_ANALYSIS_STAGE_ARG_ARG_TSFILES_HAVE_BEEN_ANALYZED_PROGRESS_ARG_PERCENT,
+ analyzedTsFileNum,
+ totalTsFileNum,
+ progress);
+ } else {
+ LOGGER.info(
+ DataNodeQueryMessages
+
.LOAD_ANALYSIS_STAGE_ARG_ARG_TSFILES_HAVE_BEEN_ANALYZED_PROGRESS_ARG_PERCENT,
+ analyzedTsFileNum,
+ totalTsFileNum,
+ progress);
+ }
+ }
+
private void analyzeSingleTsFile(final File tsFile, int i) throws Exception {
final SessionInfo sessionInfo = context.getSession();
try (final TsFileSequenceReader reader = new
TsFileSequenceReader(tsFile.getAbsolutePath())) {
// check whether the tsfile is tree-model or not
final Map<String, TableSchema> tableSchemaMap =
reader.getTableSchemaMap();
final boolean isTableModelFile = Objects.nonNull(tableSchemaMap) &&
!tableSchemaMap.isEmpty();
- LOGGER.info(
- DataNodeQueryMessages.TSFILE_ARG_IS_A_ARG_MODEL_FILE,
- tsFile.getPath(),
- isTableModelFile ? "table" : "tree");
+ if (isGeneratedByPipe) {
+ LOGGER.debug(
+ DataNodeQueryMessages.TSFILE_ARG_IS_A_ARG_MODEL_FILE,
+ tsFile.getPath(),
+ isTableModelFile ? "table" : "tree");
+ } else {
+ LOGGER.info(
+ DataNodeQueryMessages.TSFILE_ARG_IS_A_ARG_MODEL_FILE,
+ tsFile.getPath(),
+ isTableModelFile ? "table" : "tree");
+ }
// can be reused when constructing tsfile resource
final TsFileSequenceReaderTimeseriesMetadataIterator
timeseriesMetadataIterator =
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtil.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtil.java
index 0037e2f1ac9..8a39ad9d266 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtil.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/fetcher/SchemaPredicateUtil.java
@@ -226,7 +226,8 @@ public class SchemaPredicateUtil {
final int tagCount = tableInstance.getTagNum();
for (int i = 0; i < index2FilterMapList.size(); i++) {
final Map<Integer, List<SchemaFilter>> filterMap =
index2FilterMapList.get(i);
- if (filterMap.size() == tagCount
+ if (tagCount > 0
+ && filterMap.size() == tagCount
&& filterMap.values().stream()
.allMatch(
filterList ->
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
index 9ff496521cb..3f5020cccf3 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileDispatcherImpl.java
@@ -74,7 +74,7 @@ import java.util.concurrent.atomic.AtomicInteger;
import static com.google.common.util.concurrent.Futures.immediateFuture;
-public class LoadTsFileDispatcherImpl implements IFragInstanceDispatcher {
+public class LoadTsFileDispatcherImpl implements IFragInstanceDispatcher,
AutoCloseable {
private static final Logger LOGGER =
LoggerFactory.getLogger(LoadTsFileDispatcherImpl.class);
@@ -88,7 +88,7 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
private final int localhostInternalPort;
private final IClientManager<TEndPoint, SyncDataNodeInternalServiceClient>
internalServiceClientManager;
- private final ExecutorService executor;
+ private ExecutorService executor;
private final boolean isGeneratedByPipe;
public LoadTsFileDispatcherImpl(
@@ -97,11 +97,17 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
this.internalServiceClientManager = internalServiceClientManager;
this.localhostIpAddr =
IoTDBDescriptor.getInstance().getConfig().getInternalAddress();
this.localhostInternalPort =
IoTDBDescriptor.getInstance().getConfig().getInternalPort();
- this.executor =
-
IoTDBThreadPoolFactory.newCachedThreadPool(LoadTsFileDispatcherImpl.class.getName());
this.isGeneratedByPipe = isGeneratedByPipe;
}
+ private synchronized ExecutorService getOrCreateExecutor() {
+ if (executor == null || executor.isShutdown()) {
+ executor =
+
IoTDBThreadPoolFactory.newCachedThreadPool(LoadTsFileDispatcherImpl.class.getName());
+ }
+ return executor;
+ }
+
public void setUuid(String uuid) {
this.uuid = uuid;
}
@@ -109,24 +115,28 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
@Override
public Future<FragInstanceDispatchResult> dispatch(
SubPlan root, List<FragmentInstance> instances) {
- return executor.submit(
- () -> {
- for (FragmentInstance instance : instances) {
- try (SetThreadName threadName =
- new SetThreadName(
- "load-dispatcher" + "-" + instance.getId().getFullId() +
"-" + uuid)) {
- dispatchOneInstance(instance);
- } catch (FragmentInstanceDispatchException e) {
- return new FragInstanceDispatchResult(e.getFailureStatus());
- } catch (Exception t) {
-
LOGGER.warn(DataNodeQueryMessages.CANNOT_DISPATCH_FI_FOR_LOAD_OPERATION, t);
- return new FragInstanceDispatchResult(
- RpcUtils.getStatus(
- TSStatusCode.INTERNAL_SERVER_ERROR, "Unexpected errors:
" + t.getMessage()));
- }
- }
- return new FragInstanceDispatchResult(true);
- });
+ return getOrCreateExecutor()
+ .submit(
+ () -> {
+ for (FragmentInstance instance : instances) {
+ try (SetThreadName threadName =
+ new SetThreadName(
+ "load-dispatcher" + "-" + instance.getId().getFullId()
+ "-" + uuid)) {
+ dispatchOneInstance(instance);
+ } catch (FragmentInstanceDispatchException e) {
+ return new FragInstanceDispatchResult(e.getFailureStatus());
+ } catch (Exception t) {
+
LOGGER.warn(DataNodeQueryMessages.CANNOT_DISPATCH_FI_FOR_LOAD_OPERATION, t);
+ return new FragInstanceDispatchResult(
+ RpcUtils.getStatus(
+ TSStatusCode.INTERNAL_SERVER_ERROR,
+ String.format(
+
DataNodeQueryMessages.MESSAGE_UNEXPECTED_ERRORS_ARG_78EE0800,
+ t.getMessage())));
+ }
+ }
+ return new FragInstanceDispatchResult(true);
+ });
}
private void dispatchOneInstance(FragmentInstance instance)
@@ -152,7 +162,11 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
}
public void dispatchLocally(FragmentInstance instance) throws
FragmentInstanceDispatchException {
- LOGGER.info(DataNodeQueryMessages.RECEIVE_LOAD_NODE_FROM_UUID, uuid);
+ if (isGeneratedByPipe) {
+ LOGGER.debug(DataNodeQueryMessages.RECEIVE_LOAD_NODE_FROM_UUID, uuid);
+ } else {
+ LOGGER.info(DataNodeQueryMessages.RECEIVE_LOAD_NODE_FROM_UUID, uuid);
+ }
ConsensusGroupId groupId =
ConsensusGroupId.Factory.createFromTConsensusGroupId(
@@ -270,7 +284,10 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
return immediateFuture(
new FragInstanceDispatchResult(
RpcUtils.getStatus(
- TSStatusCode.INTERNAL_SERVER_ERROR, "Unexpected errors: "
+ t.getMessage())));
+ TSStatusCode.INTERNAL_SERVER_ERROR,
+ String.format(
+
DataNodeQueryMessages.MESSAGE_UNEXPECTED_ERRORS_ARG_78EE0800,
+ t.getMessage()))));
}
}
return immediateFuture(new FragInstanceDispatchResult(true));
@@ -365,6 +382,14 @@ public class LoadTsFileDispatcherImpl implements
IFragInstanceDispatcher {
@Override
public void abort() {
- // Do nothing
+ close();
+ }
+
+ @Override
+ public synchronized void close() {
+ if (executor != null) {
+ executor.shutdownNow();
+ executor = null;
+ }
}
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileScheduler.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileScheduler.java
index e304ed2310c..d3beefc0802 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileScheduler.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/scheduler/load/LoadTsFileScheduler.java
@@ -255,11 +255,19 @@ public class LoadTsFileScheduler implements IScheduler {
if (isLoadSingleTsFileSuccess) {
node.clean();
- LOGGER.info(
-
DataNodeQueryMessages.LOAD_TSFILE_ARG_SUCCESSFULLY_LOAD_PROCESS_ARG_ARG,
- filePath,
- i + 1,
- tsFileNodeListSize);
+ if (isGeneratedByPipe) {
+ LOGGER.debug(
+
DataNodeQueryMessages.LOAD_TSFILE_ARG_SUCCESSFULLY_LOAD_PROCESS_ARG_ARG,
+ filePath,
+ i + 1,
+ tsFileNodeListSize);
+ } else {
+ LOGGER.info(
+
DataNodeQueryMessages.LOAD_TSFILE_ARG_SUCCESSFULLY_LOAD_PROCESS_ARG_ARG,
+ filePath,
+ i + 1,
+ tsFileNodeListSize);
+ }
} else {
isLoadSuccess = false;
failedTsFileNodeIndexes.add(i);
@@ -313,6 +321,7 @@ public class LoadTsFileScheduler implements IScheduler {
}
}
} finally {
+ dispatcher.close();
LoadTsFileMemoryManager.getInstance().releaseDataCacheMemoryBlock();
}
}
@@ -412,7 +421,11 @@ public class LoadTsFileScheduler implements IScheduler {
private boolean secondPhase(
boolean isFirstPhaseSuccess, String uuid, TsFileResource tsFileResource)
{
- LOGGER.info(DataNodeQueryMessages.START_DISPATCHING_LOAD_COMMAND_FOR_UUID,
uuid);
+ if (isGeneratedByPipe) {
+
LOGGER.debug(DataNodeQueryMessages.START_DISPATCHING_LOAD_COMMAND_FOR_UUID,
uuid);
+ } else {
+
LOGGER.info(DataNodeQueryMessages.START_DISPATCHING_LOAD_COMMAND_FOR_UUID,
uuid);
+ }
final File tsFile = tsFileResource.getTsFile();
final TLoadCommandReq loadCommandReq =
new TLoadCommandReq(
@@ -686,7 +699,7 @@ public class LoadTsFileScheduler implements IScheduler {
@Override
public void stop(Throwable t) {
- // Do nothing
+ dispatcher.abort();
}
@Override
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
index b99cd646c2a..63a6269b190 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/DataRegion.java
@@ -4198,11 +4198,19 @@ public class DataRegion implements IDataRegionForQuery {
0);
if (!newFileName.equals(tsfileToBeInserted.getName())) {
- logger.info(
- StorageEngineMessages
-
.STORAGE_LOG_TSFILE_MUST_BE_RENAMED_TO_FOR_LOADING_INTO_THE_UNSEQUENCE_70321619,
- tsfileToBeInserted.getName(),
- newFileName);
+ if (isGeneratedByPipe) {
+ logger.debug(
+ StorageEngineMessages
+
.STORAGE_LOG_TSFILE_MUST_BE_RENAMED_TO_FOR_LOADING_INTO_THE_UNSEQUENCE_70321619,
+ tsfileToBeInserted.getName(),
+ newFileName);
+ } else {
+ logger.info(
+ StorageEngineMessages
+
.STORAGE_LOG_TSFILE_MUST_BE_RENAMED_TO_FOR_LOADING_INTO_THE_UNSEQUENCE_70321619,
+ tsfileToBeInserted.getName(),
+ newFileName);
+ }
newTsFileResource.setFile(
fsFactory.getFile(tsfileToBeInserted.getParentFile(),
newFileName));
}
@@ -4251,7 +4259,11 @@ public class DataRegion implements IDataRegionForQuery {
}
onTsFileLoaded(newTsFileResource, isFromConsensus, lastReader);
- logger.info(StorageEngineMessages.TSFILE_LOADED_IN_UNSEQ_LIST,
newFileName);
+ if (isGeneratedByPipe) {
+ logger.debug(StorageEngineMessages.TSFILE_LOADED_IN_UNSEQ_LIST,
newFileName);
+ } else {
+ logger.info(StorageEngineMessages.TSFILE_LOADED_IN_UNSEQ_LIST,
newFileName);
+ }
} catch (final DiskSpaceInsufficientException e) {
logger.error(
StorageEngineMessages
@@ -4407,10 +4419,19 @@ public class DataRegion implements IDataRegionForQuery {
return false;
}
- logger.info(
-
StorageEngineMessages.STORAGE_LOG_LOAD_TSFILE_IN_UNSEQUENCE_LIST_MOVE_FILE_FROM_TO_21E11AEB,
- tsFileToLoad.getAbsolutePath(),
- targetFile.getAbsolutePath());
+ if (isGeneratedByPipe) {
+ logger.debug(
+ StorageEngineMessages
+
.STORAGE_LOG_LOAD_TSFILE_IN_UNSEQUENCE_LIST_MOVE_FILE_FROM_TO_21E11AEB,
+ tsFileToLoad.getAbsolutePath(),
+ targetFile.getAbsolutePath());
+ } else {
+ logger.info(
+ StorageEngineMessages
+
.STORAGE_LOG_LOAD_TSFILE_IN_UNSEQUENCE_LIST_MOVE_FILE_FROM_TO_21E11AEB,
+ tsFileToLoad.getAbsolutePath(),
+ targetFile.getAbsolutePath());
+ }
LoadTsFileRateLimiter.getInstance().acquire(tsFileResource.getTsFile().length());
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java
index c39b0d93c6f..a539f1a2a73 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java
@@ -508,7 +508,7 @@ public abstract class IoTDBFileReceiver implements
IoTDBReceiver {
return;
}
- LOGGER.info(
+ LOGGER.debug(
PipeMessages.RECEIVER_WRITING_FILE_NOT_EXIST,
receiverId.get(),
fileName,
@@ -525,7 +525,7 @@ public abstract class IoTDBFileReceiver implements
IoTDBReceiver {
// This may be useless, because receiver file dir is created when
handshake. just in case.
if (!receiverFileDirWithIdSuffix.get().exists()) {
if (receiverFileDirWithIdSuffix.get().mkdirs()) {
- LOGGER.info(
+ LOGGER.debug(
PipeMessages.RECEIVER_FILE_DIR_CREATED,
receiverId.get(),
receiverFileDirWithIdSuffix.get().getPath());
@@ -540,7 +540,7 @@ public abstract class IoTDBFileReceiver implements
IoTDBReceiver {
writingFile = targetPath.toFile();
writingFileWriter = new RandomAccessFile(writingFile, "rw");
- LOGGER.info(
+ LOGGER.debug(
PipeMessages.RECEIVER_WRITING_FILE_CREATED, receiverId.get(),
writingFile.getPath());
}
@@ -697,7 +697,7 @@ public abstract class IoTDBFileReceiver implements
IoTDBReceiver {
final TSStatus status = loadFileV1(req, fileAbsolutePath);
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
shouldDeleteSealedFile = false;
- LOGGER.info(PipeMessages.RECEIVER_SEAL_FILE_SUCCESS, receiverId.get(),
fileAbsolutePath);
+ LOGGER.debug(PipeMessages.RECEIVER_SEAL_FILE_SUCCESS,
receiverId.get(), fileAbsolutePath);
} else {
PipeLogger.log(
LOGGER::warn,
@@ -805,7 +805,7 @@ public abstract class IoTDBFileReceiver implements
IoTDBReceiver {
final TSStatus status = loadFileV2(req, fileAbsolutePaths);
if (status.getCode() == TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
- LOGGER.info(PipeMessages.RECEIVER_SEAL_FILE_SUCCESS, receiverId.get(),
fileAbsolutePaths);
+ LOGGER.debug(PipeMessages.RECEIVER_SEAL_FILE_SUCCESS,
receiverId.get(), fileAbsolutePaths);
} else {
PipeLogger.log(
LOGGER::warn,
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBReceiverAgent.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBReceiverAgent.java
index c51f36d78f0..e718300978b 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBReceiverAgent.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/IoTDBReceiverAgent.java
@@ -117,14 +117,14 @@ public abstract class IoTDBReceiverAgent {
FileUtils.deleteDirectory(receiverFileDir);
return null;
});
- LOGGER.info(PipeMessages.CLEAN_RECEIVER_DIR_SUCCESS, receiverFileDir);
+ LOGGER.debug(PipeMessages.CLEAN_RECEIVER_DIR_SUCCESS, receiverFileDir);
} catch (final Exception e) {
LOGGER.warn(PipeMessages.CLEAN_RECEIVER_DIR_FAILED, receiverFileDir, e);
}
try {
FileUtils.forceMkdir(receiverFileDir);
- LOGGER.info(PipeMessages.CREATE_RECEIVER_DIR_SUCCESS, receiverFileDir);
+ LOGGER.debug(PipeMessages.CREATE_RECEIVER_DIR_SUCCESS, receiverFileDir);
} catch (final IOException e) {
LOGGER.warn(PipeMessages.CREATE_RECEIVER_DIR_FAILED, receiverFileDir, e);
}
