(iotdb) branch dev/1.3 updated: Pipe: Fixed the bug that the handling logic of return status is not of use in convert execution visitor (#14451)

[rong]

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

rong 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 87f780d4fa3 Pipe: Fixed the bug that the handling logic of return 
status is not of use in convert execution visitor (#14451)
87f780d4fa3 is described below

commit 87f780d4fa3d77eff986aa8f269bf5df2f0aa45d
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Dec 16 20:39:01 2024 +0800

    Pipe: Fixed the bug that the handling logic of return status is not of use 
in convert execution visitor (#14451)
---
 .../visitor/PipeStatementDataTypeConvertExecutionVisitor.java  | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
index db8db28b15e..1f5256d5a6f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/visitor/PipeStatementDataTypeConvertExecutionVisitor.java
@@ -110,8 +110,9 @@ public class PipeStatementDataTypeConvertExecutionVisitor
           TSStatus result;
           try {
             result =
-                IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.visitStatement(
-                    statement, statementExecutor.execute(statement));
+                statement.accept(
+                    IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
+                    statementExecutor.execute(statement));
 
             // Retry max 5 times if the write process is rejected
             for (int i = 0;
@@ -122,8 +123,9 @@ public class PipeStatementDataTypeConvertExecutionVisitor
                 i++) {
               Thread.sleep(100L * (i + 1));
               result =
-                  
IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR.visitStatement(
-                      statement, statementExecutor.execute(statement));
+                  statement.accept(
+                      IoTDBDataNodeReceiver.STATEMENT_STATUS_VISITOR,
+                      statementExecutor.execute(statement));
             }
           } catch (final Exception e) {
             if (e instanceof InterruptedException) {