(iotdb) branch WeakRead updated: Print InternalAddress and port in explain analyze

[jackietien]

This is an automated email from the ASF dual-hosted git repository.

jackietien pushed a commit to branch WeakRead
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/WeakRead by this push:
     new ccc9c2979b0 Print InternalAddress and port in explain analyze
ccc9c2979b0 is described below

commit ccc9c2979b00dd270a2c35a2b9d74af8d4a135f9
Author: JackieTien97 <jackietie...@gmail.com>
AuthorDate: Wed Aug 20 09:30:22 2025 +0800

    Print InternalAddress and port in explain analyze
---
 .../src/test/resources/confignode1conf/iotdb-system.properties        | 3 ++-
 .../src/test/resources/confignode2conf/iotdb-system.properties        | 3 ++-
 .../src/test/resources/confignode3conf/iotdb-system.properties        | 3 ++-
 .../db/queryengine/execution/fragment/FragmentInstanceExecution.java  | 4 +++-
 4 files changed, 9 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/confignode/src/test/resources/confignode1conf/iotdb-system.properties
 
b/iotdb-core/confignode/src/test/resources/confignode1conf/iotdb-system.properties
index b396e373f86..5c291816255 100644
--- 
a/iotdb-core/confignode/src/test/resources/confignode1conf/iotdb-system.properties
+++ 
b/iotdb-core/confignode/src/test/resources/confignode1conf/iotdb-system.properties
@@ -38,4 +38,5 @@ data_replication_factor=3
 udf_lib_dir=target/confignode1/ext/udf
 trigger_lib_dir=target/confignode1/ext/trigger
 pipe_lib_dir=target/confignode1/ext/pipe
-config_node_ratis_log_appender_buffer_size_max = 14194304
\ No newline at end of file
+config_node_ratis_log_appender_buffer_size_max = 14194304
+read_consistency_level=weak
\ No newline at end of file
diff --git 
a/iotdb-core/confignode/src/test/resources/confignode2conf/iotdb-system.properties
 
b/iotdb-core/confignode/src/test/resources/confignode2conf/iotdb-system.properties
index ef3ba921f96..401265a1d62 100644
--- 
a/iotdb-core/confignode/src/test/resources/confignode2conf/iotdb-system.properties
+++ 
b/iotdb-core/confignode/src/test/resources/confignode2conf/iotdb-system.properties
@@ -38,4 +38,5 @@ data_replication_factor=3
 udf_lib_dir=target/confignode2/ext/udf
 trigger_lib_dir=target/confignode2/ext/trigger
 pipe_lib_dir=target/confignode2/ext/pipe
-config_node_ratis_log_appender_buffer_size_max = 14194304
\ No newline at end of file
+config_node_ratis_log_appender_buffer_size_max = 14194304
+read_consistency_level=weak
\ No newline at end of file
diff --git 
a/iotdb-core/confignode/src/test/resources/confignode3conf/iotdb-system.properties
 
b/iotdb-core/confignode/src/test/resources/confignode3conf/iotdb-system.properties
index 48f99317a2f..cd7de57c48f 100644
--- 
a/iotdb-core/confignode/src/test/resources/confignode3conf/iotdb-system.properties
+++ 
b/iotdb-core/confignode/src/test/resources/confignode3conf/iotdb-system.properties
@@ -38,4 +38,5 @@ data_replication_factor=3
 udf_lib_dir=target/confignode3/ext/udf
 trigger_lib_dir=target/confignode3/ext/trigger
 pipe_lib_dir=target/confignode3/ext/pipe
-config_node_ratis_log_appender_buffer_size_max = 14194304
\ No newline at end of file
+config_node_ratis_log_appender_buffer_size_max = 14194304
+read_consistency_level=weak
\ No newline at end of file
diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java
index 7681475c4d1..92471853f60 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FragmentInstanceExecution.java
@@ -20,6 +20,7 @@
 package org.apache.iotdb.db.queryengine.execution.fragment;
 
 import org.apache.iotdb.commons.utils.FileUtils;
+import org.apache.iotdb.db.conf.IoTDBConfig;
 import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.queryengine.common.FragmentInstanceId;
 import org.apache.iotdb.db.queryengine.exception.CpuNotEnoughException;
@@ -53,6 +54,7 @@ import static 
org.apache.iotdb.db.queryengine.statistics.StatisticsMergeUtil.mer
 public class FragmentInstanceExecution {
 
   private static final Logger LOGGER = 
LoggerFactory.getLogger(FragmentInstanceExecution.class);
+  private static final IoTDBConfig CONFIG = 
IoTDBDescriptor.getInstance().getConfig();
   private final FragmentInstanceId instanceId;
   private final FragmentInstanceContext context;
 
@@ -152,7 +154,7 @@ public class FragmentInstanceExecution {
       return false;
     }
     statistics.setDataRegion(((DataRegion) 
context.getDataRegion()).getDataRegionId());
-    
statistics.setIp(IoTDBDescriptor.getInstance().getConfig().getAddressAndPort().ip);
+    statistics.setIp(CONFIG.getInternalAddress() + ":" + 
CONFIG.getInternalPort());
     statistics.setStartTimeInMS(context.getStartTime());
     statistics.setEndTimeInMS(
         context.isEndTimeUpdate() ? context.getEndTime() : 
System.currentTimeMillis());