(iotdb) branch master updated: Pipe: Fixed the NPE of schema sync in historical transfer (#14588)

[rong]

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

rong 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 6eaaf5a4fdf Pipe: Fixed the NPE of schema sync in historical transfer 
(#14588)
6eaaf5a4fdf is described below

commit 6eaaf5a4fdf2652ea8ecc6f1fc6d33393e765dfd
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Tue Dec 31 00:24:00 2024 +0800

    Pipe: Fixed the NPE of schema sync in historical transfer (#14588)
---
 .../java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
index 93439565575..a90623b1b31 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/schema/SRStatementGenerator.java
@@ -158,7 +158,9 @@ public class SRStatementGenerator implements 
Iterator<Statement>, Iterable<State
           lastExcept = ioe;
           try {
             inputStream.close();
-            tagFileChannel.close();
+            if (tagFileChannel != null) {
+              tagFileChannel.close();
+            }
 
           } catch (IOException e) {
             lastExcept = e;