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)