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;