You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@iotdb.apache.org by "Jialin Qiao (Jira)" <ji...@apache.org> on 2021/03/08 11:48:00 UTC

[jira] [Created] (IOTDB-1187) Unseq merge loss data after deletion

Jialin Qiao created IOTDB-1187:
----------------------------------

             Summary: Unseq merge loss data after deletion
                 Key: IOTDB-1187
                 URL: https://issues.apache.org/jira/browse/IOTDB-1187
             Project: Apache IoTDB
          Issue Type: Bug
            Reporter: Jialin Qiao


(1) Use the folowing code to write data into 0.11.2:

(2) delete from root.sg_1

(3) Then rerun the following code

(4) select count(*) from root

The count is less than 1000000.

 
{code:java}
//代码占位符
static List<Record> mockData(int loop) {
    List<Record> recordList = new ArrayList<>();
    int mockSize=10000;
    long timestamp = mockSize*loop;
    for (int r = 0; r < mockSize; r++) {
        Record record = new Record();
        String storageGroup = "root.sg_1";
        String deviceId = String.format("%s.device_1", storageGroup);
        record.setStorageGroup(storageGroup);
        record.setDeviceId(deviceId);
        record.setTimestamp(new Timestamp(timestamp+r));
        Record.Column column = new Record.Column("pressure", "Float", r%999.0f);
        record.addColumn(column);
        column = new Record.Column("temperature", "Float", r%37.0f);
        record.addColumn(column);
        recordList.add(record);
    }
    return recordList;
}

public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {

    IOTDBReader iotdbReader = new IOTDBReader();
    Session session = iotdbReader.openSession();
    for (int loop = 0; loop < 100; loop++) {
        List<Record> recordList = mockData(loop);
        iotdbReader.insertTablet(session, recordList, loop);
        System.out.println(loop);
    }
    session.close();
}
{code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)