(iotdb) branch dev/1.3 updated: Pipe: Fixed the NPE of schema sync in historical transfer (#14586)

[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 3b14f299870 Pipe: Fixed the NPE of schema sync in historical transfer 
(#14586)
3b14f299870 is described below

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

    Pipe: Fixed the NPE of schema sync in historical transfer (#14586)
---
 .../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 dcfa7958077..29caf17d7a2 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
@@ -155,7 +155,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;