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

rong pushed a commit to branch rc/1.2.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 0b16cffb31bc18f63b27ad1f4f124c9eb8cc1e12
Author: Steve Yurong Su <[email protected]>
AuthorDate: Wed Sep 27 09:51:14 2023 +0800

    Revert "[To rel/1.2] Pipe: fix NPE in 
PipeEnrichedInsertBaseStatement#isQuery when analyzing statement in metadata 
mismatch scenarios (#11203) (#11206)"
    
    This reverts commit 43b5431df26da241b163bcc16605e46e3bf7be24.
---
 .../plan/statement/crud/PipeEnrichedInsertBaseStatement.java           | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
index c6f43c3f7ac..10834b20ecc 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/PipeEnrichedInsertBaseStatement.java
@@ -32,7 +32,6 @@ import org.apache.iotdb.tsfile.write.schema.MeasurementSchema;
 
 import java.util.List;
 import java.util.Map;
-import java.util.Objects;
 
 public class PipeEnrichedInsertBaseStatement extends InsertBaseStatement {
 
@@ -68,7 +67,7 @@ public class PipeEnrichedInsertBaseStatement extends 
InsertBaseStatement {
 
   @Override
   public boolean isQuery() {
-    return !Objects.isNull(insertBaseStatement) && 
insertBaseStatement.isQuery();
+    return insertBaseStatement.isQuery();
   }
 
   @Override

Reply via email to