This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch new_vector in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit a16dfeddbcc5725280b4888dbd6aa72e0ede0439 Author: JackieTien97 <[email protected]> AuthorDate: Wed Nov 10 10:53:00 2021 +0800 fix some ci --- tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtils.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtils.java b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtils.java index ee1436f..8e27ea1 100644 --- a/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtils.java +++ b/tsfile/src/test/java/org/apache/iotdb/tsfile/utils/RecordUtils.java @@ -68,8 +68,9 @@ public class RecordUtils { for (int i = 2; i < items.length - 1; i += 2) { // get measurementId and value measurementId = items[i].trim(); - IMeasurementSchema measurementSchema = - schema.getSeriesSchema(new Path(deviceId)).getMeasurementSchemaMap().get(measurementId); + MeasurementGroup measurementGroup = schema.getSeriesSchema(new Path(deviceId)); + IMeasurementSchema measurementSchema = measurementGroup == null ? null : + measurementGroup.getMeasurementSchemaMap().get(measurementId); if (measurementSchema == null) { LOG.warn("measurementId:{},type not found, pass", measurementId); continue;
