Revert "Expose /v1/integrations/gateway/metrics for Trino Gateway"

This reverts commit 1ca42b4.

The endpoint was exposing cluster utilization metrics (memory, load),
which are generally useful for observability and also for any other query routing logic.
We should expose them in gateway-agnostic manner. Reverting now to unblock release.

Author: wendigo

core/trino-main/src/main/java/io/trino/memory/LocalMemoryManager.java

@@ -17,14 +17,11 @@
 import com.google.common.base.Supplier;
 import com.google.common.base.Suppliers;
 import com.google.inject.Inject;
-import com.sun.management.UnixOperatingSystemMXBean;
 import io.airlift.units.DataSize;
 
-import java.lang.management.ManagementFactory;
 import java.util.concurrent.TimeUnit;
 
 import static com.google.common.base.Verify.verify;
-import static java.lang.Math.clamp;
 import static java.lang.String.format;
 
 public final class LocalMemoryManager
@@ -34,10 +31,6 @@ public final class LocalMemoryManager
     private static final Supplier<Integer> AVAILABLE_PROCESSORS = Suppliers
             .memoizeWithExpiration(Runtime.getRuntime()::availableProcessors, 30, TimeUnit.SECONDS);
 
-    // Clamp value because according to the documentation: if the recent CPU usage is not available, the method returns a negative value.
-    private static final Supplier<Double> SYSTEM_CPU_LOAD = Suppliers
-            .memoizeWithExpiration(() -> clamp(((UnixOperatingSystemMXBean) ManagementFactory.getOperatingSystemMXBean()).getCpuLoad(), 0.0, 1.0), 5, TimeUnit.SECONDS);
-
     @Inject
     public LocalMemoryManager(NodeMemoryConfig config)
     {
@@ -70,7 +63,7 @@ private void validateHeapHeadroom(NodeMemoryConfig config, long availableMemory)
 
     public MemoryInfo getInfo()
     {
-        return new MemoryInfo(AVAILABLE_PROCESSORS.get(), SYSTEM_CPU_LOAD.get(), memoryPool.getInfo());
+        return new MemoryInfo(AVAILABLE_PROCESSORS.get(), memoryPool.getInfo());
     }
 
     public MemoryPool getMemoryPool()

core/trino-main/src/main/java/io/trino/memory/MemoryInfo.java

@@ -23,17 +23,14 @@
 public class MemoryInfo
 {
     private final int availableProcessors;
-    private final double systemCpuLoad;
     private final MemoryPoolInfo pool;
 
     @JsonCreator
     public MemoryInfo(
             @JsonProperty("availableProcessors") int availableProcessors,
-            @JsonProperty("systemCpuLoad") double systemCpuLoad,
             @JsonProperty("pool") MemoryPoolInfo pool)
     {
         this.availableProcessors = availableProcessors;
-        this.systemCpuLoad = systemCpuLoad;
         this.pool = requireNonNull(pool, "pool is null");
     }
 
@@ -43,12 +40,6 @@ public int getAvailableProcessors()
         return availableProcessors;
     }
 
-    @JsonProperty
-    public double getSystemCpuLoad()
-    {
-        return systemCpuLoad;
-    }
-
     @JsonProperty
     public MemoryPoolInfo getPool()
     {
@@ -60,7 +51,6 @@ public String toString()
     {
         return toStringHelper(this)
                 .add("availableProcessors", availableProcessors)
-                .add("systemCpuLoad", systemCpuLoad)
                 .add("pool", pool)
                 .toString();
     }

core/trino-main/src/main/java/io/trino/server/CoordinatorModule.java

@@ -242,8 +242,6 @@ protected void setup(Binder binder)
 
         newExporter(binder).export(ClusterMemoryManager.class).withGeneratedName();
 
-        jaxrsBinder(binder).bind(GatewayResource.class);
-
         // node partitioning manager
         binder.bind(NodePartitioningManager.class).in(Scopes.SINGLETON);
 

core/trino-main/src/main/java/io/trino/server/GatewayResource.java

@@ -179,7 +179,6 @@ private MemoryInfo buildWorkerMemoryInfo(DataSize usedMemory, Map<TaskId, DataSi
         {
             return new MemoryInfo(
                     4,
-                    0,
                     new MemoryPoolInfo(
                             DataSize.of(64, GIGABYTE).toBytes(),
                             usedMemory.toBytes(),

core/trino-main/src/test/java/io/trino/execution/scheduler/faulttolerant/BenchmarkBinPackingNodeAllocator.java

@@ -131,7 +131,6 @@ private MemoryInfo buildWorkerMemoryInfo(DataSize usedMemory, Map<TaskId, DataSi
     {
         return new MemoryInfo(
                 4,
-                0,
                 new MemoryPoolInfo(
                         DataSize.of(64, GIGABYTE).toBytes(),
                         usedMemory.toBytes(),

core/trino-main/src/test/java/io/trino/execution/scheduler/faulttolerant/TestBinPackingNodeAllocator.java

@@ -279,7 +279,6 @@ private MemoryInfo buildWorkerMemoryInfo(DataSize usedMemory)
     {
         return new MemoryInfo(
                 4,
-                0,
                 new MemoryPoolInfo(
                         DataSize.of(64, GIGABYTE).toBytes(),
                         usedMemory.toBytes(),

core/trino-main/src/test/java/io/trino/execution/scheduler/faulttolerant/TestExponentialGrowthPartitionMemoryEstimator.java

@@ -73,7 +73,7 @@ static List<MemoryInfo> toNodeMemoryInfoList(long memoryPoolMaxBytes, Map<String
                     ImmutableMap.of(),
                     tasksMemoryInfoForNode(entry.getKey().getNodeIdentifier(), tasks),
                     ImmutableMap.of());
-            result.add(new MemoryInfo(7, 0, memoryPoolInfo));
+            result.add(new MemoryInfo(7, memoryPoolInfo));
         }
         return result.build();
     }