diff --git a/src/test/kotlin/org/opensearch/indexmanagement/rollup/interceptor/ResponseInterceptorIT.kt b/src/test/kotlin/org/opensearch/indexmanagement/rollup/interceptor/ResponseInterceptorIT.kt index 461f86e4f..0b9322278 100644 --- a/src/test/kotlin/org/opensearch/indexmanagement/rollup/interceptor/ResponseInterceptorIT.kt +++ b/src/test/kotlin/org/opensearch/indexmanagement/rollup/interceptor/ResponseInterceptorIT.kt @@ -645,7 +645,7 @@ class ResponseInterceptorIT : RollupRestTestCase() { jobEnabledTime = Instant.now(), description = "basic search test", sourceIndex = "nyc-taxi-data", - targetIndex = "rollup-alias-nyc-taxi-data", + targetIndex = "rollup-nyc-taxi-data", metadataID = null, roles = emptyList(), pageSize = 10, @@ -723,14 +723,12 @@ class ResponseInterceptorIT : RollupRestTestCase() { // Validate result from searching rollup-nyc-taxi-data, searching nyc-taxi-data val start = System.currentTimeMillis() - val r = client().makeRequest( + var r = client().makeRequest( "PUT", "_cluster/settings", StringEntity( """ { "transient": { - "logger.org.opensearch.indexmanagement.rollup":"DEBUG", - "logger.org.opensearch.jobscheduler":"DEBUG", "logger.org.opensearch.transport": "Trace" } } @@ -738,11 +736,26 @@ class ResponseInterceptorIT : RollupRestTestCase() { ContentType.APPLICATION_JSON ) ) - logger.info("enable trace log $r") + logger.info("enable trace log ${r.entity.content.bufferedReader().use { it.readText() }}") logger.info("start to make search call ${Date()}") var searchAllResponse = client().makeRequest("POST", "/rollup-nyc-taxi-data,nyc-taxi-data/_search", emptyMap(), StringEntity(aggReq, ContentType.APPLICATION_JSON)) logger.info("search call finished ${Date()}") + r = client().makeRequest( + "PUT", "_cluster/settings", + StringEntity( + """ + { + "transient": { + "logger.org.opensearch.transport": null + } + } + """.trimIndent(), + ContentType.APPLICATION_JSON + ) + ) + logger.info("disable trace log ${r.entity.content.bufferedReader().use { it.readText() }}") + assertTrue(searchAllResponse.restStatus() == RestStatus.OK) var responseAggs = searchAllResponse.asMap()["aggregations"] as Map> assertEquals(