(iotdb) branch dev/1.3 updated: [To dev/1.3] Pipe: Optimized the judgement of validation for start-time and end-time key (#15872)

[justinchen]

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

justinchen pushed a commit to branch dev/1.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new 37c7c25655d [To dev/1.3] Pipe: Optimized the judgement of validation 
for start-time and end-time key (#15872)
37c7c25655d is described below

commit 37c7c25655dedd511ad4a2af6b8031a7cf50ba78
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Fri Aug 29 12:02:34 2025 +0800

    [To dev/1.3] Pipe: Optimized the judgement of validation for start-time and 
end-time key (#15872)
    
    * Pipe: Added rate limiter for tsFile sending (#15765)
    
    As the title said.
    
    * fix
---
 .../db/pipe/source/dataregion/IoTDBDataRegionSource.java   | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java
index aebd39d320c..aa046bb88e6 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/IoTDBDataRegionSource.java
@@ -188,14 +188,22 @@ public class IoTDBDataRegionSource extends IoTDBSource {
     }
 
     // Validate source.start-time and source.end-time
-    if (validator.getParameters().hasAnyAttributes(SOURCE_START_TIME_KEY, 
SOURCE_END_TIME_KEY)
+    if (validator
+            .getParameters()
+            .hasAnyAttributes(
+                SOURCE_START_TIME_KEY,
+                EXTRACTOR_START_TIME_KEY,
+                SOURCE_END_TIME_KEY,
+                EXTRACTOR_END_TIME_KEY)
         && validator
             .getParameters()
             .hasAnyAttributes(
                 EXTRACTOR_HISTORY_ENABLE_KEY,
-                EXTRACTOR_REALTIME_ENABLE_KEY,
                 SOURCE_HISTORY_ENABLE_KEY,
-                SOURCE_REALTIME_ENABLE_KEY)) {
+                SOURCE_HISTORY_START_TIME_KEY,
+                EXTRACTOR_HISTORY_START_TIME_KEY,
+                SOURCE_HISTORY_END_TIME_KEY,
+                EXTRACTOR_HISTORY_END_TIME_KEY)) {
       LOGGER.warn(
           "When {}, {}, {} or {} is specified, specifying {}, {}, {}, {}, {} 
and {} is invalid.",
           SOURCE_START_TIME_KEY,