(iotdb) 01/01: Pipe: handle OUT_OF_TTL status code when date syncing

[rong]

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

rong pushed a commit to branch handle-ttl
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 4c5e0c7f9524a764aeb09a3f973a8d195708455e
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Thu Apr 25 15:17:52 2024 +0800

    Pipe: handle OUT_OF_TTL status code when date syncing
---
 .../commons/pipe/connector/PipeReceiverStatusHandler.java     | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java
index 92a4f07019a..6cb73f38da3 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/PipeReceiverStatusHandler.java
@@ -97,6 +97,17 @@ public class PipeReceiverStatusHandler {
           return;
         }
 
+      case 607: // OUT_OF_TTL
+        {
+          if (LOGGER.isDebugEnabled()) {
+            LOGGER.debug(
+                "Out of TTL exception: will be ignored. event: {}. status: {}",
+                recordMessage,
+                status);
+          }
+          return;
+        }
+
       case 1809: // PIPE_RECEIVER_IDEMPOTENT_CONFLICT_EXCEPTION
         {
           LOGGER.info("Idempotent conflict exception: will be ignored. status: 
{}", status);