You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2021/11/10 03:30:40 UTC

[iotdb] 02/03: fix some ci

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 <Ja...@foxmail.com>
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;