@@ -681,50 +681,6 @@ public void testRunningQueriesViewDuration() throws Exception {
681681 }
682682 }
683683
684- /** Test map query flag in running queries system view. */
685- @ Test
686- public void testMapQueryRunningQueriesView () throws Exception {
687- IgniteEx ignite = startGrids (2 );
688-
689- IgniteCache <Integer , String > cache = ignite .createCache (
690- new CacheConfiguration <Integer , String >(DEFAULT_CACHE_NAME )
691- .setCacheMode (CacheMode .PARTITIONED )
692- .setIndexedTypes (Integer .class , String .class )
693- );
694-
695- for (int i = 0 ; i < 10 ; i ++)
696- cache .put (i , Integer .toString (i ));
697-
698- awaitPartitionMapExchange ();
699-
700- String initiatorId = UUID .randomUUID ().toString ();
701-
702- try (FieldsQueryCursor <List <?>> cursor = cache .query (new SqlFieldsQuery ("SELECT * FROM String" )
703- .setQueryInitiatorId (initiatorId )
704- .setPageSize (1 ))) {
705- cursor .iterator ().next ();
706-
707- for (int i = 0 ; i < 2 ; i ++) {
708- int nodeIdx = i ;
709- UUID nodeId = grid (nodeIdx ).localNode ().id ();
710-
711- assertTrue (waitForCondition (() -> {
712- SystemView <SqlQueryView > view = grid (nodeIdx ).context ().systemView ().view (SQL_QRY_VIEW );
713-
714- for (SqlQueryView qry : view ) {
715- if (qry .mapQuery ()
716- && nodeId .equals (qry .nodeId ())
717- && ignite .localNode ().id ().equals (qry .originNodeId ())
718- && initiatorId .equals (qry .initiatorId ()))
719- return true ;
720- }
721-
722- return false ;
723- }, 5_000 ));
724- }
725- }
726- }
727-
728684 /**
729685 * Test that we can't use cache tables and system views in the same query.
730686 */
0 commit comments