This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch random-opt-pipe in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit bb9895fc8bfa9e8ad13adf8d4ecafc03e4dc4b95 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Apr 2 18:37:56 2025 +0800 Pipe: Set thread name for pipe receiver --- .../org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiver.java | 4 ++++ 1 file changed, 4 insertions(+) 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 a733fcde0a6..a8c65a93808 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 @@ -115,6 +115,10 @@ public abstract class IoTDBFileReceiver implements IoTDBReceiver { } receiverId.set(RECEIVER_ID_GENERATOR.incrementAndGet()); + Thread.currentThread() + .setName( + String.format( + "Pipe-Receiver-%s-%s:%s", receiverId.get(), getSenderHost(), getSenderPort())); // Clear the original receiver file dir if exists if (receiverFileDirWithIdSuffix.get() != null) {
