You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2021/07/26 06:11:35 UTC
[iotdb] branch fix_cluster_it created (now f84d273)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch fix_cluster_it
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
at f84d273 remove unnecessary testcontainer IT
This branch includes the following new commits:
new f84d273 remove unnecessary testcontainer IT
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[iotdb] 01/01: remove unnecessary testcontainer IT
Posted by ta...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a commit to branch fix_cluster_it
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit f84d273a0e5a51ec987f82ed7934377bb191278a
Author: LebronAl <TX...@gmail.com>
AuthorDate: Mon Jul 26 14:10:52 2021 +0800
remove unnecessary testcontainer IT
---
.../test/java/org/apache/iotdb/db/sql/Cases.java | 109 ---------------------
1 file changed, 109 deletions(-)
diff --git a/testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java b/testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
index fff5fe3..c4c8178 100644
--- a/testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
+++ b/testcontainer/src/test/java/org/apache/iotdb/db/sql/Cases.java
@@ -213,79 +213,6 @@ public abstract class Cases {
}
}
- // @Test
- // public void vectorCountTest() throws IoTDBConnectionException, StatementExecutionException {
- // List<List<String>> measurementList = new ArrayList<>();
- // List<String> schemaNames = new ArrayList<>();
- // List<List<TSEncoding>> encodingList = new ArrayList<>();
- // List<List<TSDataType>> dataTypeList = new ArrayList<>();
- // List<CompressionType> compressionTypes = new ArrayList<>();
- // List<TSDataType> dataTypes = new ArrayList<>();
- // List<TSEncoding> encodings = new ArrayList<>();
- // String[] vectorMeasurements = new String[10];
- //
- // Stream.iterate(0, i -> i + 1)
- // .limit(10)
- // .forEach(
- // i -> {
- // dataTypes.add(TSDataType.DOUBLE);
- // vectorMeasurements[i] = "vm" + i;
- // encodings.add(TSEncoding.RLE);
- // compressionTypes.add(CompressionType.SNAPPY);
- // });
- // schemaNames.add("schema");
- // encodingList.add(encodings);
- // dataTypeList.add(dataTypes);
- // measurementList.add(Arrays.asList(vectorMeasurements));
- //
- // session.createSchemaTemplate(
- // "testcontainer",
- // schemaNames,
- // measurementList,
- // dataTypeList,
- // encodingList,
- // compressionTypes);
- // session.setStorageGroup("root.template");
- // session.setSchemaTemplate("testcontainer", "root.template");
- //
- // VectorMeasurementSchema vectorMeasurementSchema =
- // new VectorMeasurementSchema(
- // "vector", vectorMeasurements, dataTypes.toArray(new TSDataType[0]));
- //
- // Tablet tablet = new Tablet("root.template.device1.vector",
- // Arrays.asList(vectorMeasurementSchema));
- // tablet.setAligned(true);
- // for (int i = 0; i < 10; i++) {
- // tablet.addTimestamp(i, i);
- // for (int j = 0; j < 10; j++) {
- // tablet.addValue("vm" + j, i, (double) i);
- // tablet.rowSize++;
- // }
- // }
- // session.insertTablet(tablet);
- //
- // SessionDataSet sessionDataSet =
- // session.executeQueryStatement("select count(*) from root.template.device1");
- // Assert.assertTrue(sessionDataSet.hasNext());
- // RowRecord next = sessionDataSet.next();
- // Assert.assertEquals(10, next.getFields().get(0).getLongV());
- //
- // sessionDataSet = session.executeQueryStatement("select count(vm1) from
- // root.template.device1");
- // Assert.assertTrue(sessionDataSet.hasNext());
- // next = sessionDataSet.next();
- // Assert.assertEquals(10, next.getFields().get(0).getLongV());
- //
- // sessionDataSet =
- // session.executeQueryStatement("select count(vm1),count(vm2) from
- // root.template.device1");
- // Assert.assertTrue(sessionDataSet.hasNext());
- // next = sessionDataSet.next();
- // Assert.assertEquals(2, next.getFields().size());
- // Assert.assertEquals(10, next.getFields().get(0).getLongV());
- // Assert.assertEquals(10, next.getFields().get(1).getLongV());
- // }
-
@Test
public void clusterLastQueryTest() throws IoTDBConnectionException, StatementExecutionException {
@@ -494,42 +421,6 @@ public abstract class Cases {
}
@Test
- public void testApplyClearCache() throws InterruptedException {
- String sql = "CLEAR CACHE";
- try {
- // Wait for 3S so that the leader can be elected
- Thread.sleep(3000);
- writeStatement.execute(sql);
- } catch (SQLException e) {
- Assert.assertNull(e);
- }
- }
-
- @Test
- public void testApplyMerge() throws InterruptedException {
- String sql = "MERGE";
- try {
- // Wait for 3S so that the leader can be elected
- Thread.sleep(3000);
- writeStatement.execute(sql);
- } catch (SQLException e) {
- Assert.assertNull(e);
- }
- }
-
- @Test
- public void testCreateSnapshot() throws InterruptedException {
- String sql = "CREATE SNAPSHOT FOR SCHEMA";
- try {
- // Wait for 3S so that the leader can be elected
- Thread.sleep(3000);
- writeStatement.execute(sql);
- } catch (SQLException e) {
- Assert.assertNull(e);
- }
- }
-
- @Test
public void clusterUDTFQueryTest() throws SQLException {
// Prepare data.
writeStatement.execute(