(iotdb) branch master updated: Fixed the bug that a pre-updated table may face multiple updates and generate NPE

[ja...@apache.org]

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

jackietien 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 aaa9a9b86e3 Fixed the bug that a pre-updated table may face multiple updates and generate NPE
aaa9a9b86e3 is described below

commit aaa9a9b86e34c8477c00c368079c9dc87450de65
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Thu Nov 28 18:24:12 2024 +0800

    Fixed the bug that a pre-updated table may face multiple updates and generate NPE
---
 .../java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java
index 525470f6f9c..3d49790fc4f 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/table/DataNodeTableCache.java
@@ -338,6 +338,7 @@ public class DataNodeTableCache implements ITableCache {
                     final Pair<TsTable, Long> existingPair =
                         preUpdateTableMap.get(database).get(tableName);
                     if (Objects.isNull(existingPair)
+                        || Objects.isNull(existingPair.getLeft())
                         || !Objects.equals(
                             existingPair.getRight(),
                             previousVersions.get(database).get(tableName))) {