chesnokoff commented on code in PR #13091:
URL: https://github.com/apache/ignite/pull/13091#discussion_r3179584473
##########
modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/SqlSystemViewsSelfTest.java:
##########
@@ -681,50 +681,6 @@ public void testRunningQueriesViewDuration() throws
Exception {
}
}
- /** Test map query flag in running queries system view. */
- @Test
- public void testMapQueryRunningQueriesView() throws Exception {
- IgniteEx ignite = startGrids(2);
-
- IgniteCache<Integer, String> cache = ignite.createCache(
- new CacheConfiguration<Integer, String>(DEFAULT_CACHE_NAME)
- .setCacheMode(CacheMode.PARTITIONED)
- .setIndexedTypes(Integer.class, String.class)
- );
-
- for (int i = 0; i < 10; i++)
- cache.put(i, Integer.toString(i));
-
- awaitPartitionMapExchange();
-
- String initiatorId = UUID.randomUUID().toString();
-
- try (FieldsQueryCursor<List<?>> cursor = cache.query(new
SqlFieldsQuery("SELECT * FROM String")
- .setQueryInitiatorId(initiatorId)
- .setPageSize(1))) {
- cursor.iterator().next();
-
- for (int i = 0; i < 2; i++) {
- int nodeIdx = i;
- UUID nodeId = grid(nodeIdx).localNode().id();
-
- assertTrue(waitForCondition(() -> {
- SystemView<SqlQueryView> view =
grid(nodeIdx).context().systemView().view(SQL_QRY_VIEW);
-
- for (SqlQueryView qry : view) {
- if (qry.mapQuery()
- && nodeId.equals(qry.nodeId())
- &&
ignite.localNode().id().equals(qry.originNodeId())
- && initiatorId.equals(qry.initiatorId()))
- return true;
- }
-
- return false;
- }, 5_000));
- }
- }
- }
Review Comment:
Initially, created this test to check map queries but now I think the test
may be flaky so I decided to rollback it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
