This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 732fa7716e [IOTDB-3489] Add test name to log folder in cluster test
(#6279)
732fa7716e is described below
commit 732fa7716e4ddf77d51ff75f23f91d0a43c16564
Author: BaiJian <[email protected]>
AuthorDate: Wed Jun 15 08:40:30 2022 +0800
[IOTDB-3489] Add test name to log folder in cluster test (#6279)
---
.../org/apache/iotdb/it/env/ClusterEnvBase.java | 16 +-
.../org/apache/iotdb/it/env/IoTDBTestRunner.java | 44 ++++++
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 4 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 2 +
.../iotdb/itbase/runtime/ClusterTestResultSet.java | 176 ++++++++-------------
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 3 +
.../iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 3 +
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 3 +
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 7 +
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 7 +
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 7 +
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 3 +
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 3 +
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 3 +
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 3 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 3 +
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 3 +
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 3 +
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 3 +
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 3 +
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 8 +-
23 files changed, 192 insertions(+), 121 deletions(-)
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvBase.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvBase.java
index a4b1bb2b1d..6f1dd50019 100644
--- a/integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvBase.java
+++ b/integration-test/src/main/java/org/apache/iotdb/it/env/ClusterEnvBase.java
@@ -47,12 +47,16 @@ public abstract class ClusterEnvBase implements BaseEnv {
private List<ConfigNode> configNodes;
private List<DataNode> dataNodes;
private final Random rand = new Random();
+ private String nextTestCase = null;
protected void initEnvironment(int configNodesNum, int dataNodesNum) throws
InterruptedException {
this.configNodes = new ArrayList<>();
this.dataNodes = new ArrayList<>();
String testName = getTestClassName();
+ if (nextTestCase != null) {
+ testName = testName + "_" + nextTestCase;
+ }
ConfigNode seedConfigNode = new ConfigNode(true, "", testName);
seedConfigNode.createDir();
@@ -94,6 +98,7 @@ public abstract class ClusterEnvBase implements BaseEnv {
configNode.waitingToShutDown();
configNode.destroyDir();
}
+ nextTestCase = null;
}
public String getTestClassName() {
@@ -110,9 +115,9 @@ public abstract class ClusterEnvBase implements BaseEnv {
public String getTestClassNameAndDate() {
Date date = new Date();
SimpleDateFormat formatter = new SimpleDateFormat("yyyyMMdd-HHmmss");
- StackTraceElement stack[] = Thread.currentThread().getStackTrace();
- for (int i = 0; i < stack.length; i++) {
- String className = stack[i].getClassName();
+ StackTraceElement[] stack = Thread.currentThread().getStackTrace();
+ for (StackTraceElement stackTraceElement : stack) {
+ String className = stackTraceElement.getClassName();
if (className.endsWith("IT")) {
return className.substring(className.lastIndexOf(".") + 1) + "-" +
formatter.format(date);
}
@@ -165,6 +170,11 @@ public abstract class ClusterEnvBase implements BaseEnv {
return new ClusterTestConnection(getWriteConnection(null),
getReadConnections(null));
}
+ @Override
+ public void setNextTestCaseName(String testCaseName) {
+ nextTestCase = testCaseName;
+ }
+
private IoTDBConnection getConnection(int queryTimeout) throws SQLException {
IoTDBConnection connection =
(IoTDBConnection)
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
new file mode 100644
index 0000000000..433c7dc357
--- /dev/null
+++
b/integration-test/src/main/java/org/apache/iotdb/it/env/IoTDBTestRunner.java
@@ -0,0 +1,44 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.iotdb.it.env;
+
+import org.junit.runner.Description;
+import org.junit.runner.notification.RunNotifier;
+import org.junit.runners.BlockJUnit4ClassRunner;
+import org.junit.runners.model.FrameworkMethod;
+import org.junit.runners.model.InitializationError;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class IoTDBTestRunner extends BlockJUnit4ClassRunner {
+
+ private static final Logger logger =
LoggerFactory.getLogger(IoTDBTestRunner.class);
+
+ public IoTDBTestRunner(Class<?> testClass) throws InitializationError {
+ super(testClass);
+ }
+
+ @Override
+ protected void runChild(final FrameworkMethod method, RunNotifier notifier) {
+ Description description = describeChild(method);
+ logger.info("Run {}", description.getMethodName());
+ EnvFactory.getEnv().setNextTestCaseName(description.getMethodName());
+ super.runChild(method, notifier);
+ }
+}
diff --git
a/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
b/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
index bb206cd836..4bf339f335 100644
---
a/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
+++
b/integration-test/src/main/java/org/apache/iotdb/it/env/RemoteServerEnv.java
@@ -104,4 +104,8 @@ public class RemoteServerEnv implements BaseEnv {
}
return connection;
}
+
+ public void setNextTestCaseName(String testCaseName) {
+ // Do nothing
+ }
}
diff --git
a/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
b/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
index b7d3d30ca5..5ed57e05b8 100644
--- a/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
+++ b/integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseEnv.java
@@ -36,4 +36,6 @@ public interface BaseEnv {
Connection getConnection() throws SQLException;
Connection getConnection(Constant.Version version) throws SQLException;
+
+ void setNextTestCaseName(String testCaseName);
}
diff --git
a/integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
b/integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
index a3fa82ca11..e98ff7e7c1 100644
---
a/integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
+++
b/integration-test/src/main/java/org/apache/iotdb/itbase/runtime/ClusterTestResultSet.java
@@ -84,7 +84,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public boolean wasNull() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
+ RequestDelegate<Boolean> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(rs::wasNull);
}
@@ -93,7 +93,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public String getString(int columnIndex) throws SQLException {
- RequestDelegate<String> delegate = createRequestDelegate();
+ RequestDelegate<String> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getString(columnIndex));
}
@@ -102,7 +102,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public boolean getBoolean(int columnIndex) throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
+ RequestDelegate<Boolean> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBoolean(columnIndex));
}
@@ -111,7 +111,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public byte getByte(int columnIndex) throws SQLException {
- RequestDelegate<Byte> delegate = createRequestDelegate();
+ RequestDelegate<Byte> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getByte(columnIndex));
}
@@ -120,7 +120,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public short getShort(int columnIndex) throws SQLException {
- RequestDelegate<Short> delegate = createRequestDelegate();
+ RequestDelegate<Short> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getShort(columnIndex));
}
@@ -129,7 +129,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public int getInt(int columnIndex) throws SQLException {
- RequestDelegate<Integer> delegate = createRequestDelegate();
+ RequestDelegate<Integer> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getInt(columnIndex));
}
@@ -138,7 +138,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public long getLong(int columnIndex) throws SQLException {
- RequestDelegate<Long> delegate = createRequestDelegate();
+ RequestDelegate<Long> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getLong(columnIndex));
}
@@ -147,7 +147,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public float getFloat(int columnIndex) throws SQLException {
- RequestDelegate<Float> delegate = createRequestDelegate();
+ RequestDelegate<Float> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getFloat(columnIndex));
}
@@ -156,7 +156,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public double getDouble(int columnIndex) throws SQLException {
- RequestDelegate<Double> delegate = createRequestDelegate();
+ RequestDelegate<Double> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getDouble(columnIndex));
}
@@ -165,7 +165,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public BigDecimal getBigDecimal(int columnIndex, int scale) throws
SQLException {
- RequestDelegate<BigDecimal> delegate = createRequestDelegate();
+ RequestDelegate<BigDecimal> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBigDecimal(columnIndex));
}
@@ -174,7 +174,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public byte[] getBytes(int columnIndex) throws SQLException {
- RequestDelegate<byte[]> delegate = createRequestDelegate();
+ RequestDelegate<byte[]> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBytes(columnIndex));
}
@@ -183,7 +183,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Date getDate(int columnIndex) throws SQLException {
- RequestDelegate<Date> delegate = createRequestDelegate();
+ RequestDelegate<Date> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getDate(columnIndex));
}
@@ -192,7 +192,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Time getTime(int columnIndex) throws SQLException {
- RequestDelegate<Time> delegate = createRequestDelegate();
+ RequestDelegate<Time> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getTime(columnIndex));
}
@@ -201,7 +201,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Timestamp getTimestamp(int columnIndex) throws SQLException {
- RequestDelegate<Timestamp> delegate = createRequestDelegate();
+ RequestDelegate<Timestamp> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getTimestamp(columnIndex));
}
@@ -225,7 +225,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public String getString(String columnLabel) throws SQLException {
- RequestDelegate<String> delegate = createRequestDelegate();
+ RequestDelegate<String> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getString(columnLabel));
}
@@ -234,7 +234,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public boolean getBoolean(String columnLabel) throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
+ RequestDelegate<Boolean> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBoolean(columnLabel));
}
@@ -243,7 +243,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public byte getByte(String columnLabel) throws SQLException {
- RequestDelegate<Byte> delegate = createRequestDelegate();
+ RequestDelegate<Byte> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getByte(columnLabel));
}
@@ -252,7 +252,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public short getShort(String columnLabel) throws SQLException {
- RequestDelegate<Short> delegate = createRequestDelegate();
+ RequestDelegate<Short> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getShort(columnLabel));
}
@@ -261,7 +261,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public int getInt(String columnLabel) throws SQLException {
- RequestDelegate<Integer> delegate = createRequestDelegate();
+ RequestDelegate<Integer> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getInt(columnLabel));
}
@@ -270,7 +270,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public long getLong(String columnLabel) throws SQLException {
- RequestDelegate<Long> delegate = createRequestDelegate();
+ RequestDelegate<Long> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getLong(columnLabel));
}
@@ -279,7 +279,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public float getFloat(String columnLabel) throws SQLException {
- RequestDelegate<Float> delegate = createRequestDelegate();
+ RequestDelegate<Float> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getFloat(columnLabel));
}
@@ -288,7 +288,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public double getDouble(String columnLabel) throws SQLException {
- RequestDelegate<Double> delegate = createRequestDelegate();
+ RequestDelegate<Double> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getDouble(columnLabel));
}
@@ -297,7 +297,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public BigDecimal getBigDecimal(String columnLabel, int scale) throws
SQLException {
- RequestDelegate<BigDecimal> delegate = createRequestDelegate();
+ RequestDelegate<BigDecimal> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBigDecimal(columnLabel));
}
@@ -306,7 +306,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public byte[] getBytes(String columnLabel) throws SQLException {
- RequestDelegate<byte[]> delegate = createRequestDelegate();
+ RequestDelegate<byte[]> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBytes(columnLabel));
}
@@ -315,7 +315,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Date getDate(String columnLabel) throws SQLException {
- RequestDelegate<Date> delegate = createRequestDelegate();
+ RequestDelegate<Date> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getDate(columnLabel));
}
@@ -324,7 +324,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Time getTime(String columnLabel) throws SQLException {
- RequestDelegate<Time> delegate = createRequestDelegate();
+ RequestDelegate<Time> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getTime(columnLabel));
}
@@ -333,7 +333,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Timestamp getTimestamp(String columnLabel) throws SQLException {
- RequestDelegate<Timestamp> delegate = createRequestDelegate();
+ RequestDelegate<Timestamp> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getTimestamp(columnLabel));
}
@@ -372,7 +372,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public ResultSetMetaData getMetaData() throws SQLException {
- RequestDelegate<ResultSetMetaData> delegate = createRequestDelegate();
+ RequestDelegate<ResultSetMetaData> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(rs::getMetaData);
}
@@ -382,7 +382,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Object getObject(int columnIndex) throws SQLException {
- RequestDelegate<Object> delegate = createRequestDelegate();
+ RequestDelegate<Object> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getObject(columnIndex));
}
@@ -391,7 +391,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public Object getObject(String columnLabel) throws SQLException {
- RequestDelegate<Object> delegate = createRequestDelegate();
+ RequestDelegate<Object> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getObject(columnLabel));
}
@@ -400,7 +400,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public int findColumn(String columnLabel) throws SQLException {
- RequestDelegate<Integer> delegate = createRequestDelegate();
+ RequestDelegate<Integer> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.findColumn(columnLabel));
}
@@ -419,7 +419,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public BigDecimal getBigDecimal(int columnIndex) throws SQLException {
- RequestDelegate<BigDecimal> delegate = createRequestDelegate();
+ RequestDelegate<BigDecimal> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBigDecimal(columnIndex));
}
@@ -428,7 +428,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public BigDecimal getBigDecimal(String columnLabel) throws SQLException {
- RequestDelegate<BigDecimal> delegate = createRequestDelegate();
+ RequestDelegate<BigDecimal> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(() -> rs.getBigDecimal(columnLabel));
}
@@ -436,119 +436,63 @@ public class ClusterTestResultSet implements ResultSet {
}
@Override
- public boolean isBeforeFirst() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::isBeforeFirst);
- }
- return delegate.requestAllAndCompare();
+ public boolean isBeforeFirst() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean isAfterLast() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::isAfterLast);
- }
- return delegate.requestAllAndCompare();
+ public boolean isAfterLast() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean isFirst() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::isFirst);
- }
- return delegate.requestAllAndCompare();
+ public boolean isFirst() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean isLast() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::isLast);
- }
- return delegate.requestAllAndCompare();
+ public boolean isLast() {
+ throw new UnsupportedOperationException();
}
@Override
- public void beforeFirst() throws SQLException {
- RequestDelegate<Void> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(
- () -> {
- rs.beforeFirst();
- return null;
- });
- }
- delegate.requestAll();
+ public void beforeFirst() {
+ throw new UnsupportedOperationException();
}
@Override
- public void afterLast() throws SQLException {
- RequestDelegate<Void> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(
- () -> {
- rs.afterLast();
- return null;
- });
- }
- delegate.requestAll();
+ public void afterLast() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean first() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::first);
- }
- return delegate.requestAllAndCompare();
+ public boolean first() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean last() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::last);
- }
- return delegate.requestAllAndCompare();
+ public boolean last() {
+ throw new UnsupportedOperationException();
}
@Override
- public int getRow() throws SQLException {
- RequestDelegate<Integer> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::getRow);
- }
- return delegate.requestAllAndCompare();
+ public int getRow() {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean absolute(int row) throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(() -> rs.absolute(row));
- }
- return delegate.requestAllAndCompare();
+ public boolean absolute(int row) {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean relative(int rows) throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(() -> rs.relative(rows));
- }
- return delegate.requestAllAndCompare();
+ public boolean relative(int rows) {
+ throw new UnsupportedOperationException();
}
@Override
- public boolean previous() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
- for (ResultSet rs : resultSets) {
- delegate.addRequest(rs::previous);
- }
- return delegate.requestAllAndCompare();
+ public boolean previous() {
+ throw new UnsupportedOperationException();
}
@Override
@@ -983,7 +927,7 @@ public class ClusterTestResultSet implements ResultSet {
@Override
public boolean isClosed() throws SQLException {
- RequestDelegate<Boolean> delegate = createRequestDelegate();
+ RequestDelegate<Boolean> delegate = createLocalRequestDelegate();
for (ResultSet rs : resultSets) {
delegate.addRequest(rs::isClosed);
}
@@ -1227,4 +1171,8 @@ public class ClusterTestResultSet implements ResultSet {
private <T> RequestDelegate<T> createRequestDelegate() {
return new ParallelRequestDelegate<>(endpoints, queryTimeoutSeconds);
}
+
+ private <T> RequestDelegate<T> createLocalRequestDelegate() {
+ return new SerialRequestDelegate<>(endpoints);
+ }
}
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
index cc05d5f929..dd4176003b 100644
--- a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
+++ b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBExampleIT.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.it;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -28,12 +29,14 @@ import org.junit.Assert;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
/** This is an example for integration test. */
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBExampleIT {
@BeforeClass
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
index 278353c122..6861f83e47 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBUDTFBuiltinFunctionIT.java
@@ -20,12 +20,14 @@
package org.apache.iotdb.db.it;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -39,6 +41,7 @@ import static org.junit.Assert.fail;
// TODO @Category({LocalStandaloneIT.class, ClusterIT.class})
// After bug of init MultiInputColumnIntermediateLayer fixed
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class})
public class IoTDBUDTFBuiltinFunctionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
index cb74784fee..5d22310bcc 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery2IT.java
@@ -20,13 +20,16 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBAlignedSeriesQuery2IT extends IoTDBAlignedSeriesQueryIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
index d5555ff875..d663893231 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQuery3IT.java
@@ -20,13 +20,16 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBAlignedSeriesQuery3IT extends IoTDBAlignedSeriesQueryIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
index 5e488440a3..b9cab8fd19 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBAlignedSeriesQueryIT.java
@@ -20,6 +20,7 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -27,6 +28,7 @@ import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -48,6 +50,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBAlignedSeriesQueryIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
index 55a22749a3..c480eca06c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues2IT.java
@@ -20,10 +20,15 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
+import org.apache.iotdb.itbase.category.ClusterIT;
+import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -32,6 +37,8 @@ import java.sql.Statement;
import static org.junit.Assert.assertEquals;
+@RunWith(IoTDBTestRunner.class)
+@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBInsertAlignedValues2IT {
private int numOfPointsPerPage;
private boolean autoCreateSchemaEnabled;
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
index 11c99feb45..51e764ee98 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues3IT.java
@@ -20,10 +20,15 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
+import org.apache.iotdb.itbase.category.ClusterIT;
+import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -32,6 +37,8 @@ import java.sql.Statement;
import static org.junit.Assert.assertEquals;
+@RunWith(IoTDBTestRunner.class)
+@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBInsertAlignedValues3IT {
private int numOfPointsPerPage;
private boolean autoCreateSchemaEnabled;
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
index 0afc85d0cf..28b9dab516 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValues4IT.java
@@ -20,10 +20,15 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
+import org.apache.iotdb.itbase.category.ClusterIT;
+import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
+import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.SQLException;
@@ -31,6 +36,8 @@ import java.sql.Statement;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
+@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBInsertAlignedValues4IT {
private boolean autoCreateSchemaEnabled;
private int primitiveArraySize;
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
index 3840230cb5..0c6894a21c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBInsertAlignedValuesIT.java
@@ -21,6 +21,7 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -29,6 +30,7 @@ import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -41,6 +43,7 @@ import static org.junit.Assert.assertNull;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBInsertAlignedValuesIT {
private boolean autoCreateSchemaEnabled;
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
index 66e70700be..b614dca45e 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletion2IT.java
@@ -20,18 +20,21 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.Statement;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithDeletion2IT extends
IoTDBLastQueryWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
index 8dddbe9444..9b1d64d211 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithDeletionIT.java
@@ -20,6 +20,7 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -27,6 +28,7 @@ import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -45,6 +47,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
index 8882cdb719..1fd490faa1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCache2IT.java
@@ -20,13 +20,16 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithoutLastCache2IT extends
IoTDBLastQueryWithoutLastCacheIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
index d662945e51..d63f00302e 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheIT.java
@@ -20,6 +20,7 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -27,6 +28,7 @@ import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -45,6 +47,7 @@ import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithoutLastCacheIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
index 27f12867e8..989e07a76a 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletion2IT.java
@@ -20,18 +20,21 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.Statement;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithoutLastCacheWithDeletion2IT
extends IoTDBLastQueryWithoutLastCacheWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
index 9d75b705c2..a0d79541f3 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBLastQueryWithoutLastCacheWithDeletionIT.java
@@ -20,18 +20,21 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.Statement;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBLastQueryWithoutLastCacheWithDeletionIT extends
IoTDBLastQueryWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
index f97225fff7..6ea9ceb205 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletion2IT.java
@@ -20,12 +20,14 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.Statement;
@@ -33,6 +35,7 @@ import java.sql.Statement;
import static org.junit.Assert.fail;
/** IoTDBRawQueryWithoutValueFilter2IT */
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBRawQueryWithoutValueFilterWithDeletion2IT
extends IoTDBRawQueryWithoutValueFilterWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
index 41f734a329..c0c162d3dc 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/aligned/IoTDBRawQueryWithoutValueFilterWithDeletionIT.java
@@ -20,6 +20,7 @@ package org.apache.iotdb.db.it.aligned;
import org.apache.iotdb.it.env.ConfigFactory;
import org.apache.iotdb.it.env.EnvFactory;
+import org.apache.iotdb.it.env.IoTDBTestRunner;
import org.apache.iotdb.itbase.category.ClusterIT;
import org.apache.iotdb.itbase.category.LocalStandaloneIT;
@@ -27,6 +28,7 @@ import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;
+import org.junit.runner.RunWith;
import java.sql.Connection;
import java.sql.ResultSet;
@@ -39,6 +41,7 @@ import java.util.Map;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.fail;
+@RunWith(IoTDBTestRunner.class)
@Category({LocalStandaloneIT.class, ClusterIT.class})
public class IoTDBRawQueryWithoutValueFilterWithDeletionIT {
diff --git
a/integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
b/integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
index 63280c70e5..efe6c728b2 100644
---
a/integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
+++
b/integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
@@ -23,9 +23,6 @@ import org.apache.iotdb.itbase.env.BaseEnv;
import org.apache.iotdb.jdbc.Config;
import org.apache.iotdb.jdbc.Constant;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
@@ -35,7 +32,6 @@ import static org.junit.Assert.fail;
/** This class is used by EnvFactory with using reflection. */
public class StandaloneEnv implements BaseEnv {
- Logger logger = LoggerFactory.getLogger(StandaloneEnv.class);
@Override
public void initBeforeClass() {
@@ -90,4 +86,8 @@ public class StandaloneEnv implements BaseEnv {
}
return null;
}
+
+ public void setNextTestCaseName(String testCaseName) {
+ // Do nothing
+ }
}
