5454import static oracle .weblogic .kubernetes .assertions .TestAssertions .operatorIsReady ;
5555import static oracle .weblogic .kubernetes .utils .CommonMiiTestUtils .createMiiDomainAndVerify ;
5656import static oracle .weblogic .kubernetes .utils .CommonTestUtils .testUntil ;
57- import static oracle .weblogic .kubernetes .utils .CommonTestUtils .withStandardRetryPolicy ;
57+ import static oracle .weblogic .kubernetes .utils .CommonTestUtils .withLongRetryPolicy ;
5858import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .configMapExist ;
5959import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .createConfigMapFromFiles ;
6060import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .replaceConfigMap ;
@@ -279,7 +279,7 @@ void testLogLevelSearch() {
279279 String queryCriteria = "/_count?q=level:INFO" ;
280280
281281 // verify log level query results
282- withStandardRetryPolicy .untilAsserted (
282+ withLongRetryPolicy .untilAsserted (
283283 () -> assertTrue (verifyCountsHitsInSearchResults (queryCriteria , regex , LOGSTASH_INDEX_KEY , true ),
284284 "Query logs of level=INFO failed" ));
285285
@@ -297,9 +297,13 @@ void testOperatorLogSearch() {
297297 String regex = ".*took\" :(\\ d+),.*hits\" :\\ {(.+)\\ }" ;
298298 String queryCriteria = "/_search?q=type:weblogic-operator" ;
299299
300- verifyCountsHitsInSearchResults (queryCriteria , regex , LOGSTASH_INDEX_KEY , false );
300+ // verify results of query of type:weblogic-operator in Operator log
301+ withLongRetryPolicy .untilAsserted (
302+ () -> assertTrue (verifyCountsHitsInSearchResults (queryCriteria , regex , LOGSTASH_INDEX_KEY , false ),
303+ "Query Operator log info q=type:weblogic-operator failed" ));
301304
302- logger .info ("Query Operator log info succeeded" );
305+
306+ logger .info ("Query Operator log info q=type:weblogic-operator succeeded" );
303307 }
304308
305309 /**
@@ -431,7 +435,7 @@ private static void createAndVerifyDomain(String miiImage) {
431435
432436 private void verifyServerRunningInSearchResults (String serverName ) {
433437 String queryCriteria = "/_search?q=log:" + serverName ;
434- withStandardRetryPolicy .untilAsserted (
438+ withLongRetryPolicy .untilAsserted (
435439 () -> assertTrue (execSearchQuery (queryCriteria , LOGSTASH_INDEX_KEY ).contains ("RUNNING" ),
436440 String .format ("serverName %s is not RUNNING" , serverName )));
437441
@@ -539,7 +543,7 @@ private void verifyLogstashConfigMapModifyResult(String replaceStr) {
539543 }
540544
541545 // wait for logstash config modified and verify
542- withStandardRetryPolicy .untilAsserted (
546+ withLongRetryPolicy .untilAsserted (
543547 () -> assertTrue (copyConfigFromPodAndSearchForString (containerName , replaceStr ),
544548 String .format ("Failed to find search string %s" , replaceStr )));
545549 }
0 commit comments