This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch StableCI in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ea5bec9ea82a95c861957804540e0d6a44620b98 Author: JackieTien97 <[email protected]> AuthorDate: Thu Sep 4 09:42:22 2025 +0800 Try to make CI more stable --- .../iotdb/relational/it/query/recent/IoTDBDistinctTagIT.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDistinctTagIT.java b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDistinctTagIT.java index 6508a71c9f9..9ef5622a850 100644 --- a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDistinctTagIT.java +++ b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBDistinctTagIT.java @@ -34,6 +34,7 @@ import org.junit.runner.RunWith; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; +import java.util.concurrent.TimeUnit; import static org.apache.iotdb.db.it.utils.TestUtils.tableResultSetEqualTest; import static org.junit.Assert.fail; @@ -71,6 +72,8 @@ public class IoTDBDistinctTagIT { "insert into t2(time, deviceId, attr1, s1) values(6000, 'd4', 'a4', 11)", "insert into t2(time, deviceId, attr1, s1) values(3000, 'd2', 'a2', 12)", "insert into t2(time, deviceId, attr1, s1) values(2000, 'd1', 'a1', 13)", + "clear attribute cache", + "clear all cache", }; @BeforeClass @@ -197,6 +200,7 @@ public class IoTDBDistinctTagIT { "insert into t3(time, deviceId, attr1, s1) values(4000, 'd1', 'a1', 13)", "flush", "delete from test.t3", + "clear all cache", // test memory "CREATE TABLE IF NOT EXISTS t4(deviceId STRING TAG, attr1 STRING ATTRIBUTE, s1 INT64 FIELD)", @@ -205,6 +209,7 @@ public class IoTDBDistinctTagIT { "insert into t4(time, deviceId, attr1, s1) values(2000, 'd2', 'xx', 12)", "insert into t4(time, deviceId, attr1, s1) values(4000, 'd1', 'a1', 13)", "delete from test.t4", + "clear all cache", }; try (Connection connection = EnvFactory.getEnv().getConnection(BaseEnv.TABLE_SQL_DIALECT); @@ -251,6 +256,9 @@ public class IoTDBDistinctTagIT { for (String sql : SQLs) { statement.execute(sql); } + + // try to wait attribute cache cleared + TimeUnit.SECONDS.sleep(5); } catch (Exception e) { fail(e.getMessage()); }
