[IOTDB-1371] NPE when creating aligned timeseries and inserting with mismatched data type

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 0.13.0
• Component/s: Core/Schema Manager
• Labels: pull-request-available
• Assignee: Zesong Sun
• Reporter: Zesong Sun
• Created: 11/May/21 03:20
• Updated: 13/May/21 01:14
• Resolved: 13/May/21 01:14

Description

When creating aligned timeseries and inserting with mismatched data type, the MNode will be null and a NullPointerException would be thrown.

Here is the related test:

@Test
  public void testCreateAlignedTimeseriesAndInsertWithMismatchDataType() {
    MManager manager = IoTDB.metaManager;
    try {
      manager.setStorageGroup(new PartialPath("root.laptop"));
      manager.createAlignedTimeSeries(
          new PartialPath("root.laptop.d1"),
          Arrays.asList("s1", "s2", "s3"),
          Arrays.asList(
              TSDataType.valueOf("FLOAT"),
              TSDataType.valueOf("INT64"),
              TSDataType.valueOf("INT32")),
          Arrays.asList(
              TSEncoding.valueOf("RLE"), TSEncoding.valueOf("RLE"), TSEncoding.valueOf("RLE")),
          compressionType);

      // construct an insertRowPlan with mismatch data type
      long time = 1L;
      TSDataType[] dataTypes =
          new TSDataType[] {TSDataType.FLOAT, TSDataType.DOUBLE, TSDataType.INT32};

      String[] columns = new String[3];
      columns[0] = 2.0 + "";
      columns[1] = 10000 + "";
      columns[2] = 100 + "";

      InsertRowPlan insertRowPlan =
          new InsertRowPlan(
              new PartialPath("root.laptop.d1"),
              time,
              new String[] {"(s1,s2,s3)"},
              dataTypes,
              columns);
      insertRowPlan.setMeasurementMNodes(
          new MeasurementMNode[insertRowPlan.getMeasurements().length]);

      // call getSeriesSchemasAndReadLockDevice
      MNode mNode = manager.getSeriesSchemasAndReadLockDevice(insertRowPlan);
      assertEquals(4, mNode.getMeasurementMNodeCount());
      assertNull(insertRowPlan.getMeasurementMNodes()[0]);
      assertEquals(1, insertRowPlan.getFailedMeasurementNumber());

    } catch (Exception e) {
      e.printStackTrace();
      fail(e.getMessage());
    }
  }
}

 

Issue Links

• links to: GitHub Pull Request #3164