Skip to content

Commit 6cb9637

Browse files
committed
IGNITE-28341: Create cache explicitly in IgniteSqlSplitterSelfTest
1 parent 22c30ef commit 6cb9637

1 file changed

Lines changed: 10 additions & 3 deletions

File tree

modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2056,7 +2056,9 @@ public void testAvgVariousDataTypes() throws Exception {
20562056
*/
20572057
@Test
20582058
public void testLeftJoinWithSubquery() throws Exception {
2059-
IgniteCache<?, ?> cache = grid(0).cache(DEFAULT_CACHE_NAME);
2059+
IgniteCache<?, ?> cache = ignite(0).getOrCreateCache(
2060+
cacheConfig("psLeftJoinSubquery", true, Integer.class, Person.class)
2061+
);
20602062

20612063
String personTbl = "PERSON_LEFT_JOIN_SUBQUERY";
20622064
String depTbl = "DEPARTMENT_LEFT_JOIN_SUBQUERY";
@@ -2095,8 +2097,13 @@ public void testLeftJoinWithSubquery() throws Exception {
20952097
assertTrue(res.isEmpty());
20962098
}
20972099
finally {
2098-
cache.query(new SqlFieldsQuery("DROP TABLE IF EXISTS " + personTbl)).getAll();
2099-
cache.query(new SqlFieldsQuery("DROP TABLE IF EXISTS " + depTbl)).getAll();
2100+
try {
2101+
cache.query(new SqlFieldsQuery("DROP TABLE IF EXISTS " + personTbl)).getAll();
2102+
cache.query(new SqlFieldsQuery("DROP TABLE IF EXISTS " + depTbl)).getAll();
2103+
}
2104+
finally {
2105+
cache.destroy();
2106+
}
21002107
}
21012108
}
21022109

0 commit comments

Comments
 (0)