This is an automated email from the ASF dual-hosted git repository.
rong 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 80b7805e3e4 Subscription IT: explicitly declare `setUp` method for
test class to avoid `UNKNOWN-IT` test class name (#13565)
80b7805e3e4 is described below
commit 80b7805e3e4ab7dd3398a1b867dd76be27d1158e
Author: V_Galaxy <[email protected]>
AuthorDate: Mon Sep 23 10:02:32 2024 +0800
Subscription IT: explicitly declare `setUp` method for test class to avoid
`UNKNOWN-IT` test class name (#13565)
---
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 7 +++++++
.../subscription/it/dual/IoTDBSubscriptionTopicIT.java | 7 +++++++
.../subscription/it/local/IoTDBSubscriptionBasicIT.java | 7 +++++++
.../it/local/IoTDBSubscriptionDataTypeIT.java | 7 +++++++
.../it/local/IoTDBSubscriptionIdempotentIT.java | 7 +++++++
.../subscription/it/local/IoTDBSubscriptionTopicIT.java | 17 ++++++++++++-----
.../param/IoTDBTestParamSubscriptionSessionIT.java | 7 +++++++
7 files changed, 54 insertions(+), 5 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
index a9eef996012..4327b7a00f0 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
@@ -30,6 +30,7 @@ import
org.apache.iotdb.session.subscription.payload.SubscriptionMessage;
import org.apache.iotdb.subscription.it.IoTDBSubscriptionITConstant;
import org.apache.tsfile.write.record.Tablet;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -55,6 +56,12 @@ public class IoTDBSubscriptionTimePrecisionIT extends
AbstractSubscriptionDualIT
private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBSubscriptionTimePrecisionIT.class);
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Override
protected void setUpConfig() {
super.setUpConfig();
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTopicIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTopicIT.java
index 1317dd2dbf0..984a1bc482c 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTopicIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTopicIT.java
@@ -44,6 +44,7 @@ import org.apache.tsfile.read.expression.QueryExpression;
import org.apache.tsfile.read.query.dataset.QueryDataSet;
import org.apache.tsfile.write.record.Tablet;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -73,6 +74,12 @@ public class IoTDBSubscriptionTopicIT extends
AbstractSubscriptionDualIT {
private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBSubscriptionTopicIT.class);
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Override
protected void setUpConfig() {
super.setUpConfig();
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
index 12e50050196..72ee5c5ca70 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionBasicIT.java
@@ -39,6 +39,7 @@ import org.apache.tsfile.read.common.Path;
import org.apache.tsfile.read.expression.QueryExpression;
import org.apache.tsfile.read.query.dataset.QueryDataSet;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -65,6 +66,12 @@ public class IoTDBSubscriptionBasicIT extends
AbstractSubscriptionLocalIT {
private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBSubscriptionBasicIT.class);
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Test
public void testBasicPullConsumerWithCommitAsync() throws Exception {
// Insert some historical data
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionDataTypeIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionDataTypeIT.java
index 723b088aac3..d102b2da081 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionDataTypeIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionDataTypeIT.java
@@ -41,6 +41,7 @@ import org.apache.tsfile.read.query.dataset.QueryDataSet;
import org.apache.tsfile.utils.Binary;
import org.apache.tsfile.write.record.Tablet;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -64,6 +65,12 @@ public class IoTDBSubscriptionDataTypeIT extends
AbstractSubscriptionLocalIT {
private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBSubscriptionDataTypeIT.class);
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
// ----------------------------- //
// SessionDataSetsHandler format //
// ----------------------------- //
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
index 85fff437f18..73b866ce673 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionIdempotentIT.java
@@ -26,6 +26,7 @@ import
org.apache.iotdb.session.subscription.SubscriptionSession;
import org.apache.iotdb.session.subscription.consumer.SubscriptionPullConsumer;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -40,6 +41,12 @@ public class IoTDBSubscriptionIdempotentIT extends
AbstractSubscriptionLocalIT {
private static final Logger LOGGER =
LoggerFactory.getLogger(IoTDBSubscriptionIdempotentIT.class);
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Test
public void testSubscribeOrUnsubscribeNonExistedTopicTest() {
final String host = EnvFactory.getEnv().getIP();
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicIT.java
index 55f618b83f4..270bf05f910 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/local/IoTDBSubscriptionTopicIT.java
@@ -26,6 +26,7 @@ import
org.apache.iotdb.session.subscription.SubscriptionSession;
import org.apache.iotdb.session.subscription.model.Topic;
import org.junit.Assert;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -39,8 +40,14 @@ import static org.junit.Assert.fail;
@Category({LocalStandaloneIT.class})
public class IoTDBSubscriptionTopicIT extends AbstractSubscriptionLocalIT {
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Test
- public void testBasicCreateTopic() throws Exception {
+ public void testBasicCreateTopic() {
final String host = EnvFactory.getEnv().getIP();
final int port = Integer.parseInt(EnvFactory.getEnv().getPort());
@@ -76,7 +83,7 @@ public class IoTDBSubscriptionTopicIT extends
AbstractSubscriptionLocalIT {
}
@Test
- public void testBasicCreateTopicIfNotExists() throws Exception {
+ public void testBasicCreateTopicIfNotExists() {
final String host = EnvFactory.getEnv().getIP();
final int port = Integer.parseInt(EnvFactory.getEnv().getPort());
@@ -118,7 +125,7 @@ public class IoTDBSubscriptionTopicIT extends
AbstractSubscriptionLocalIT {
topic = session.getTopic(topicName);
Assert.assertTrue(topic.isPresent());
Assert.assertEquals(topicName, topic.get().getTopicName());
- // Verify Topic Parameters
+ // verify Topic Parameters
Assert.assertTrue(topic.get().getTopicAttributes().contains("path=root.**"));
Assert.assertTrue(topic.get().getTopicAttributes().contains("start-time=2023-01-01"));
Assert.assertFalse(topic.get().getTopicAttributes().contains("start-time=2023-01-02"));
@@ -131,7 +138,7 @@ public class IoTDBSubscriptionTopicIT extends
AbstractSubscriptionLocalIT {
}
@Test
- public void testBasicDropTopic() throws Exception {
+ public void testBasicDropTopic() {
final String host = EnvFactory.getEnv().getIP();
final int port = Integer.parseInt(EnvFactory.getEnv().getPort());
@@ -152,7 +159,7 @@ public class IoTDBSubscriptionTopicIT extends
AbstractSubscriptionLocalIT {
}
@Test
- public void testBasicDropTopicIfExists() throws Exception {
+ public void testBasicDropTopicIfExists() {
final String host = EnvFactory.getEnv().getIP();
final int port = Integer.parseInt(EnvFactory.getEnv().getPort());
diff --git
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
index b4c62837c3d..f148129d610 100644
---
a/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
@@ -25,6 +25,7 @@ import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.session.subscription.SubscriptionSession;
import
org.apache.iotdb.subscription.it.triple.regression.AbstractSubscriptionRegressionIT;
+import org.junit.Before;
import org.junit.Test;
import org.junit.experimental.categories.Category;
import org.junit.runner.RunWith;
@@ -33,6 +34,12 @@ import org.junit.runner.RunWith;
@Category({MultiClusterIT2SubscriptionRegressionMisc.class})
public class IoTDBTestParamSubscriptionSessionIT extends
AbstractSubscriptionRegressionIT {
+ @Override
+ @Before
+ public void setUp() throws Exception {
+ super.setUp();
+ }
+
@Test
public void testCreateSession_null_host() {
new SubscriptionSession.Builder().host(null).build();
