54
54
import static oracle .weblogic .kubernetes .assertions .TestAssertions .operatorIsReady ;
55
55
import static oracle .weblogic .kubernetes .utils .CommonMiiTestUtils .createMiiDomainAndVerify ;
56
56
import 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 ;
58
58
import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .configMapExist ;
59
59
import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .createConfigMapFromFiles ;
60
60
import static oracle .weblogic .kubernetes .utils .ConfigMapUtils .replaceConfigMap ;
@@ -279,7 +279,7 @@ void testLogLevelSearch() {
279
279
String queryCriteria = "/_count?q=level:INFO" ;
280
280
281
281
// verify log level query results
282
- withStandardRetryPolicy .untilAsserted (
282
+ withLongRetryPolicy .untilAsserted (
283
283
() -> assertTrue (verifyCountsHitsInSearchResults (queryCriteria , regex , LOGSTASH_INDEX_KEY , true ),
284
284
"Query logs of level=INFO failed" ));
285
285
@@ -297,9 +297,13 @@ void testOperatorLogSearch() {
297
297
String regex = ".*took\" :(\\ d+),.*hits\" :\\ {(.+)\\ }" ;
298
298
String queryCriteria = "/_search?q=type:weblogic-operator" ;
299
299
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" ));
301
304
302
- logger .info ("Query Operator log info succeeded" );
305
+
306
+ logger .info ("Query Operator log info q=type:weblogic-operator succeeded" );
303
307
}
304
308
305
309
/**
@@ -431,7 +435,7 @@ private static void createAndVerifyDomain(String miiImage) {
431
435
432
436
private void verifyServerRunningInSearchResults (String serverName ) {
433
437
String queryCriteria = "/_search?q=log:" + serverName ;
434
- withStandardRetryPolicy .untilAsserted (
438
+ withLongRetryPolicy .untilAsserted (
435
439
() -> assertTrue (execSearchQuery (queryCriteria , LOGSTASH_INDEX_KEY ).contains ("RUNNING" ),
436
440
String .format ("serverName %s is not RUNNING" , serverName )));
437
441
@@ -539,7 +543,7 @@ private void verifyLogstashConfigMapModifyResult(String replaceStr) {
539
543
}
540
544
541
545
// wait for logstash config modified and verify
542
- withStandardRetryPolicy .untilAsserted (
546
+ withLongRetryPolicy .untilAsserted (
543
547
() -> assertTrue (copyConfigFromPodAndSearchForString (containerName , replaceStr ),
544
548
String .format ("Failed to find search string %s" , replaceStr )));
545
549
}
0 commit comments