This is an automated email from the ASF dual-hosted git repository.
justinchen 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 a29bf52950e Pipe: Fixed the NPE bug in historical user parsing (#16584)
a29bf52950e is described below
commit a29bf52950e76e0994044bddea7b241dd528c41f
Author: Caideyipi <[email protected]>
AuthorDate: Wed Oct 15 14:15:37 2025 +0800
Pipe: Fixed the NPE bug in historical user parsing (#16584)
---
.../PipeHistoricalDataRegionTsFileAndDeletionSource.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
index 868bb035c5f..09fcabaa62b 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java
@@ -374,8 +374,11 @@ public class
PipeHistoricalDataRegionTsFileAndDeletionSource
}
userId =
- parameters.getStringByKeys(
- PipeSourceConstant.EXTRACTOR_IOTDB_USER_ID,
PipeSourceConstant.SOURCE_IOTDB_USER_ID);
+ parameters.getStringOrDefault(
+ Arrays.asList(
+ PipeSourceConstant.EXTRACTOR_IOTDB_USER_ID,
+ PipeSourceConstant.SOURCE_IOTDB_USER_ID),
+ "-1");
userName =
parameters.getStringByKeys(
PipeSourceConstant.EXTRACTOR_IOTDB_USER_KEY,
