Disable GCedMemoryUsage if no concurrent GC MXBean

Signed-off-by: Lantao Jin <ltjin@amazon.com>

Author: LantaoJin

integ-test/src/test/java/org/opensearch/sql/ppl/ResourceMonitorIT.java

@@ -5,9 +5,7 @@
 
 package org.opensearch.sql.ppl;
 
-import static org.opensearch.sql.legacy.TestsConstants.TEST_INDEX_DOG;
-import static org.opensearch.sql.util.MatcherUtils.columnName;
-import static org.opensearch.sql.util.MatcherUtils.verifyColumn;
+import static org.opensearch.sql.util.MatcherUtils.verifyNumOfRows;
 
 import java.io.IOException;
 import org.hamcrest.Matchers;
@@ -21,17 +19,19 @@ public class ResourceMonitorIT extends PPLIntegTestCase {
   @Override
   public void init() throws Exception {
     super.init();
-    loadIndex(Index.DOG);
+    loadIndex(Index.CLICK_BENCH);
   }
 
   @Test
   public void queryExceedResourceLimitShouldFail() throws IOException {
     // update plugins.ppl.query.memory_limit to 1%
     updateClusterSettings(
         new ClusterSetting("persistent", Settings.Key.QUERY_MEMORY_LIMIT.getKeyValue(), "1%"));
-    String query = String.format("search source=%s age=20", TEST_INDEX_DOG);
+    // ClickBench Q30 is high memory consumption query.
+    String query = sanitize(loadFromFile("clickbench/queries/q30.ppl"));
 
-    ResponseException exception = expectThrows(ResponseException.class, () -> executeQuery(query));
+    ResponseException exception =
+        expectThrows(ResponseException.class, () -> executeQueryMultipleTimes(query));
     assertEquals(500, exception.getResponse().getStatusLine().getStatusCode());
     assertThat(
         exception.getMessage(),
@@ -40,7 +40,14 @@ public void queryExceedResourceLimitShouldFail() throws IOException {
     // update plugins.ppl.query.memory_limit to default value 85%
     updateClusterSettings(
         new ClusterSetting("persistent", Settings.Key.QUERY_MEMORY_LIMIT.getKeyValue(), "85%"));
-    JSONObject result = executeQuery(String.format("search source=%s", TEST_INDEX_DOG));
-    verifyColumn(result, columnName("dog_name"), columnName("holdersName"), columnName("age"));
+    executeQueryMultipleTimes(query);
+  }
+
+  /** Run the same query multiple times in case GC can be triggered in integration test */
+  private void executeQueryMultipleTimes(String query) throws IOException {
+    for (int i = 0; i < 10; i++) {
+      JSONObject result = executeQuery(query);
+      verifyNumOfRows(result, 1);
+    }
   }
 }

opensearch/src/main/java/org/opensearch/sql/opensearch/monitor/GCedMemoryUsage.java

@@ -56,12 +56,18 @@ public void setUsage(long value) {
   }
 
   private void registerGCListener() {
-    boolean registered = false;
     List<GarbageCollectorMXBean> gcBeans = ManagementFactory.getGarbageCollectorMXBeans();
+    if (gcBeans.stream()
+        .filter(b -> b instanceof NotificationEmitter)
+        .noneMatch(b -> containConcurrentGcBean(b.getName()))) {
+      // Concurrent Garbage Collector MXBean only existed since Java 21.
+      // fallback to RuntimeMemoryUsage
+      LOG.info("No Concurrent Garbage Collector MXBean, fallback to RuntimeMemoryUsage");
+      throw new OpenSearchMemoryHealthy.MemoryUsageException();
+    }
     for (GarbageCollectorMXBean gcBean : gcBeans) {
       if (gcBean instanceof NotificationEmitter && isOldGenGc(gcBean.getName())) {
         LOG.info("{} listener registered for memory usage monitor.", gcBean.getName());
-        registered = true;
         NotificationEmitter emitter = (NotificationEmitter) gcBean;
         emitter.addNotificationListener(
             new OldGenGCListener(),
@@ -78,11 +84,10 @@ private void registerGCListener() {
             null);
       }
     }
-    if (!registered) {
-      // fallback to RuntimeMemoryUsage
-      LOG.info("No old gen GC listener registered, fallback to RuntimeMemoryUsage");
-      throw new OpenSearchMemoryHealthy.MemoryUsageException();
-    }
+  }
+
+  private boolean containConcurrentGcBean(String beanName) {
+    return beanName.toLowerCase(Locale.ROOT).contains("concurrent");
   }
 
   private boolean isOldGenGc(String gcKeyword) {