[iotdb] branch master updated: [IOTDB-4499][RestApi] Unsupported to insert multiple rows of data (#7543)

[haonan]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new b7513070da [IOTDB-4499][RestApi] Unsupported to insert multiple rows 
of data (#7543)
b7513070da is described below

commit b7513070dabe3f5c28634501edfc8de79bc809a2
Author: CloudWise-Lukemiao 
<76942485+cloudwise-lukem...@users.noreply.github.com>
AuthorDate: Sat Oct 8 16:50:54 2022 +0800

    [IOTDB-4499][RestApi] Unsupported to insert multiple rows of data (#7543)
---
 .../iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java    | 9 ++++++---
 .../iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java       | 9 ++++++---
 2 files changed, 12 insertions(+), 6 deletions(-)

diff --git 
a/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
index 8822e72ac3..2d25296773 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/GrafanaApiServiceImpl.java
@@ -124,7 +124,8 @@ public class GrafanaApiServiceImpl extends 
GrafanaApiService {
               PARTITION_FETCHER,
               SCHEMA_FETCHER,
               config.getQueryTimeoutThreshold());
-      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+          && result.status.code != 
TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
         return Response.ok()
             .entity(
                 new ExecutionStatus()
@@ -186,7 +187,8 @@ public class GrafanaApiServiceImpl extends 
GrafanaApiService {
               PARTITION_FETCHER,
               SCHEMA_FETCHER,
               config.getQueryTimeoutThreshold());
-      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+          && result.status.code != 
TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
         return Response.ok()
             .entity(
                 new ExecutionStatus()
@@ -242,7 +244,8 @@ public class GrafanaApiServiceImpl extends 
GrafanaApiService {
                 PARTITION_FETCHER,
                 SCHEMA_FETCHER,
                 config.getQueryTimeoutThreshold());
-        if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) 
{
+        if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+            && result.status.code != 
TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
           return Response.ok()
               .entity(
                   new ExecutionStatus()
diff --git 
a/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
 
b/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
index f8c2643d16..a91dd5bf96 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/protocol/mpprest/impl/RestApiServiceImpl.java
@@ -101,7 +101,8 @@ public class RestApiServiceImpl extends RestApiService {
 
       return Response.ok()
           .entity(
-              result.status.code == TSStatusCode.SUCCESS_STATUS.getStatusCode()
+              (result.status.code == 
TSStatusCode.SUCCESS_STATUS.getStatusCode()
+                      || result.status.code == 
TSStatusCode.NEED_REDIRECTION.getStatusCode())
                   ? new ExecutionStatus()
                       .code(TSStatusCode.SUCCESS_STATUS.getStatusCode())
                       .message(TSStatusCode.SUCCESS_STATUS.name())
@@ -137,7 +138,8 @@ public class RestApiServiceImpl extends RestApiService {
               PARTITION_FETCHER,
               SCHEMA_FETCHER,
               config.getQueryTimeoutThreshold());
-      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()) {
+      if (result.status.code != TSStatusCode.SUCCESS_STATUS.getStatusCode()
+          && result.status.code != 
TSStatusCode.NEED_REDIRECTION.getStatusCode()) {
         return Response.ok()
             .entity(
                 new ExecutionStatus()
@@ -185,7 +187,8 @@ public class RestApiServiceImpl extends RestApiService {
 
       return Response.ok()
           .entity(
-              result.status.code == TSStatusCode.SUCCESS_STATUS.getStatusCode()
+              (result.status.code == 
TSStatusCode.SUCCESS_STATUS.getStatusCode()
+                      || result.status.code == 
TSStatusCode.NEED_REDIRECTION.getStatusCode())
                   ? new ExecutionStatus()
                       .code(TSStatusCode.SUCCESS_STATUS.getStatusCode())
                       .message(TSStatusCode.SUCCESS_STATUS.name())