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 <[email protected]> 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(
