Enable trace log

Signed-off-by: bowenlan-amzn <bowenlan23@gmail.com>
bowenlan-amzn · Sep 8, 2023 · 316d1f7 · 316d1f7
1 parent 78c53f4
commit 316d1f7
Showing 1 changed file with 18 additions and 5 deletions.
diff --git 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,26 +723,39 @@ 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"
                     }
                 }
                 """.trimIndent(),
                 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<String, Map<String, Any>>
         assertEquals(