Skip to content

Commit a29bf52

Browse files
authored
Pipe: Fixed the NPE bug in historical user parsing (apache#16584)
1 parent 4c037e7 commit a29bf52

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/dataregion/historical/PipeHistoricalDataRegionTsFileAndDeletionSource.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -374,8 +374,11 @@ public void customize(
374374
}
375375

376376
userId =
377-
parameters.getStringByKeys(
378-
PipeSourceConstant.EXTRACTOR_IOTDB_USER_ID, PipeSourceConstant.SOURCE_IOTDB_USER_ID);
377+
parameters.getStringOrDefault(
378+
Arrays.asList(
379+
PipeSourceConstant.EXTRACTOR_IOTDB_USER_ID,
380+
PipeSourceConstant.SOURCE_IOTDB_USER_ID),
381+
"-1");
379382
userName =
380383
parameters.getStringByKeys(
381384
PipeSourceConstant.EXTRACTOR_IOTDB_USER_KEY,

0 commit comments

Comments
 (0)