(iotdb) branch throw-exception-connector updated: Update PipeStatementTSStatusVisitor.java

[rong]

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

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


The following commit(s) were added to refs/heads/throw-exception-connector by 
this push:
     new 62ea89447f7 Update PipeStatementTSStatusVisitor.java
62ea89447f7 is described below

commit 62ea89447f72e2a45fe71ebe633dfbae06d391c0
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Mon Mar 18 21:25:47 2024 +0800

    Update PipeStatementTSStatusVisitor.java
---
 .../iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java      | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java
index 18b7a06b0c9..a5374a8a77f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTSStatusVisitor.java
@@ -109,23 +109,23 @@ public class PipeStatementTSStatusVisitor extends 
StatementVisitor<TSStatus, TSS
   @Override
   public TSStatus visitCreateMultiTimeseries(
       CreateMultiTimeSeriesStatement createMultiTimeSeriesStatement, TSStatus 
context) {
-    return 
visitGeneralInternalCreateTimeseries(createMultiTimeSeriesStatement, context);
+    return visitGeneralCreateMultiTimeseries(createMultiTimeSeriesStatement, 
context);
   }
 
   @Override
   public TSStatus visitInternalCreateTimeseries(
       InternalCreateTimeSeriesStatement internalCreateTimeSeriesStatement, 
TSStatus context) {
-    return 
visitGeneralInternalCreateTimeseries(internalCreateTimeSeriesStatement, 
context);
+    return 
visitGeneralCreateMultiTimeseries(internalCreateTimeSeriesStatement, context);
   }
 
   @Override
   public TSStatus visitInternalCreateMultiTimeSeries(
       InternalCreateMultiTimeSeriesStatement 
internalCreateMultiTimeSeriesStatement,
       TSStatus context) {
-    return 
visitGeneralInternalCreateTimeseries(internalCreateMultiTimeSeriesStatement, 
context);
+    return 
visitGeneralCreateMultiTimeseries(internalCreateMultiTimeSeriesStatement, 
context);
   }
 
-  private TSStatus visitGeneralInternalCreateTimeseries(
+  private TSStatus visitGeneralCreateMultiTimeseries(
       Statement internalCreateTimeSeriesStatement, TSStatus context) {
     if (context.getCode() == TSStatusCode.MULTIPLE_ERROR.getStatusCode()) {
       for (TSStatus status : context.getSubStatus()) {